Mercurial > repos > rliterman > csp2
diff CSP2/CSP2_env/env-d9b9114564458d9d-741b3de822f2aaca6c6caa4325c4afce/opt/bbmap-39.01-1/current/sketch/AlignmentJob.java @ 68:5028fdace37b
planemo upload commit 2e9511a184a1ca667c7be0c6321a36dc4e3d116d
author | jpayne |
---|---|
date | Tue, 18 Mar 2025 16:23:26 -0400 |
parents | |
children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/CSP2/CSP2_env/env-d9b9114564458d9d-741b3de822f2aaca6c6caa4325c4afce/opt/bbmap-39.01-1/current/sketch/AlignmentJob.java Tue Mar 18 16:23:26 2025 -0400 @@ -0,0 +1,40 @@ +package sketch; + +import java.util.concurrent.ArrayBlockingQueue; + +public class AlignmentJob { + + AlignmentJob(Comparison c_, ArrayBlockingQueue<Comparison> dest_){ + c=c_; + dest=dest_; + } + + void doWork(){ + assert(!isPoison()); + try { + c.ssuIdentity(); + }catch (Throwable t){ + t.printStackTrace(); + } + put(); + } + + private void put(){ + boolean success=false; + while(!success){ + try { + dest.put(c); + success=true; + } catch (InterruptedException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } + } + + final boolean isPoison(){return c==null;} + + final Comparison c; + final ArrayBlockingQueue<Comparison> dest; + +} \ No newline at end of file