view 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 source
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;
	
}