File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
reconstruction/ai/src/main/java/org/jlab/service/ai Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 1717import ai .djl .translate .TranslateException ;
1818import java .io .IOException ;
1919import java .util .concurrent .BlockingQueue ;
20- import java .util .concurrent .LinkedBlockingQueue ;
20+ import java .util .concurrent .ArrayBlockingQueue ;
2121
2222import org .jlab .clas .reco .ReconstructionEngine ;
2323import org .jlab .io .base .DataBank ;
@@ -39,7 +39,7 @@ public class DCDenoiseEngine extends ReconstructionEngine {
3939 public static class PredictorPool {
4040 final BlockingQueue <Predictor > pool ;
4141 public PredictorPool (int size , ZooModel model ) {
42- pool = new LinkedBlockingQueue <>(size );
42+ pool = new ArrayBlockingQueue <>(size );
4343 for (int i =0 ; i <size ; i ++) pool .offer (model .newPredictor ());
4444 }
4545 public Predictor get () throws InterruptedException {
You can’t perform that action at this time.
0 commit comments