Switch to new CascadedThreadPool

1 files changed, 3 insertions, 3 deletions

diff --git a/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java b/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java
index 8b6d197..f3831b0 100644
--- a/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java
+++ b/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java
@@ -33,7 +33,7 @@ import org.openslx.filetransfer.Uploader;
 import org.openslx.imagemaster.Globals;
 import org.openslx.imagemaster.db.mappers.DbImage;
 import org.openslx.thrifthelper.ImagePublishDataEx;
-import org.openslx.util.GrowingThreadPoolExecutor;
+import org.openslx.util.CascadedThreadPoolExecutor;
 import org.openslx.util.QuickTimer;
 import org.openslx.util.QuickTimer.Task;
 
@@ -53,9 +53,9 @@ public class ConnectionHandler implements IncomingEvent
 
 	private static Map<String, OutgoingTransfer> outgoingTransfers = new ConcurrentHashMap<>();
 	private static IncomingEvent eventHandler = new ConnectionHandler();
-	private final ExecutorService transferPool = new GrowingThreadPoolExecutor( 1, MAX_TRANSFERS * 2, 1, TimeUnit.MINUTES,
+	private final ExecutorService transferPool = new CascadedThreadPoolExecutor( 1, MAX_TRANSFERS * 2, 1, TimeUnit.MINUTES,
 			new SynchronousQueue<Runnable>(),
-			new PrioThreadFactory( "TransferPool", Thread.NORM_PRIORITY - 2 ) );
+			new PrioThreadFactory( "TransferPool", Thread.NORM_PRIORITY - 2 ), null );
 
 	private static final Listener plainListener;
 	private static final Listener sslListener;