1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
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;
}
|
