From 4a471e3137daabcb9df543e6b3235a0c4183fe41 Mon Sep 17 00:00:00 2001 From: nathan Date: Sun, 6 Mar 2016 23:58:54 +0100 Subject: [PATCH] Updated object pool --- Dorkbox-Util/src/dorkbox/util/parallel/ParallelProcessor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/Dorkbox-Util/src/dorkbox/util/parallel/ParallelProcessor.java b/Dorkbox-Util/src/dorkbox/util/parallel/ParallelProcessor.java index c134b05..9a8f55c 100644 --- a/Dorkbox-Util/src/dorkbox/util/parallel/ParallelProcessor.java +++ b/Dorkbox-Util/src/dorkbox/util/parallel/ParallelProcessor.java @@ -51,7 +51,7 @@ class ParallelProcessor { this.totalTaskCount = totalTaskCount - 1; // x-1 because our ID's start at 0, not 1 this.collector = collector; - pool = new ObjectPool(poolableObject, numberOfThreads); + pool = ObjectPool.Blocking(poolableObject, numberOfThreads); this.processedCount = new AtomicInteger(); this.assignedCount = new AtomicInteger(); @@ -102,7 +102,7 @@ class ParallelProcessor { collector.taskComplete(work); final int i = processedCount.getAndIncrement(); - pool.release(work); // last valid position for 'work', since this releases it back so the client can reuse it + pool.put(work); // last valid position for 'work', since this releases it back so the client can reuse it if (i == totalTaskCount) { isShuttingDown = true;