From 2e6f46e451410a6e4522a720471827af79a3afb9 Mon Sep 17 00:00:00 2001
From: Jesse Boyd <jessepaleg@gmail.com>
Date: Mon, 11 Nov 2019 20:14:57 +0000
Subject: [PATCH] Fix QueueHandler uncache

---
 .../fawe/beta/implementation/queue/QueueHandler.java   | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/worldedit-core/src/main/java/com/boydti/fawe/beta/implementation/queue/QueueHandler.java b/worldedit-core/src/main/java/com/boydti/fawe/beta/implementation/queue/QueueHandler.java
index 82ad93be9..4c8beb6f9 100644
--- a/worldedit-core/src/main/java/com/boydti/fawe/beta/implementation/queue/QueueHandler.java
+++ b/worldedit-core/src/main/java/com/boydti/fawe/beta/implementation/queue/QueueHandler.java
@@ -267,6 +267,14 @@ public abstract class QueueHandler implements Trimable, Runnable {
         queuePool.set(null);
     }
 
+    private IQueueExtent pool() {
+        IQueueExtent queue = queuePool.get();
+        if (queue == null) {
+            queuePool.set(queue = queuePool.init());
+        }
+        return queue;
+    }
+
     public abstract void startSet(boolean parallel);
 
     public abstract void endSet(boolean parallel);
@@ -276,7 +284,7 @@ public abstract class QueueHandler implements Trimable, Runnable {
     }
 
     public IQueueExtent getQueue(World world, IBatchProcessor processor) {
-        final IQueueExtent queue = queuePool.get();
+        final IQueueExtent queue = pool();
         IChunkCache<IChunkGet> cacheGet = getOrCreateWorldCache(world);
         IChunkCache<IChunkSet> set = null; // TODO cache?
         queue.init(world, cacheGet, set);