fail fast

baltzell · baltzell · commit d87c6965d326 · 2025-10-13T18:42:45.000-04:00
diff --git a/reconstruction/ai/src/main/java/org/jlab/service/ai/DCDenoiseEngine.java b/reconstruction/ai/src/main/java/org/jlab/service/ai/DCDenoiseEngine.java
@@ -41,7 +41,7 @@ public static class PredictorPool {
         final BlockingQueue<Predictor> pool;
         public PredictorPool(int size, ZooModel model) {
             pool = new ArrayBlockingQueue<>(size);
-            for (int i=0; i<size; i++) pool.offer(model.newPredictor());
+            for (int i=0; i<size; i++) pool.add(model.newPredictor());
         }
         public Predictor get() throws InterruptedException {
             return pool.take();

Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@ public static class PredictorPool {`
`41`	`41`	`final BlockingQueue<Predictor> pool;`
`42`	`42`	`public PredictorPool(int size, ZooModel model) {`
`43`	`43`	`pool = new ArrayBlockingQueue<>(size);`
`44`		`- for (int i=0; i<size; i++) pool.offer(model.newPredictor());`
	`44`	`+ for (int i=0; i<size; i++) pool.add(model.newPredictor());`
`45`	`45`	`}`
`46`	`46`	`public Predictor get() throws InterruptedException {`
`47`	`47`	`return pool.take();`