diff options
| author | Simon Rettberg | 2016-01-08 09:42:37 +0100 |
|---|---|---|
| committer | Simon Rettberg | 2016-01-08 09:42:37 +0100 |
| commit | b16debb689473300191f0b5e8efbcd079fee2aae (patch) | |
| tree | ebda9500b60af719d6896abcc223ef67fbe14698 /dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/fileserv/SyncTransferHandler.java | |
| parent | [client] change checkbox for lecture location showing mode to radio buttons (diff) | |
| download | tutor-module-b16debb689473300191f0b5e8efbcd079fee2aae.tar.gz tutor-module-b16debb689473300191f0b5e8efbcd079fee2aae.tar.xz tutor-module-b16debb689473300191f0b5e8efbcd079fee2aae.zip | |
[server] Use GrowingThreadPoolExecutor everywhere
Diffstat (limited to 'dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/fileserv/SyncTransferHandler.java')
| -rw-r--r-- | dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/fileserv/SyncTransferHandler.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/fileserv/SyncTransferHandler.java b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/fileserv/SyncTransferHandler.java index 29f47e05..f7a9de85 100644 --- a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/fileserv/SyncTransferHandler.java +++ b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/fileserv/SyncTransferHandler.java @@ -6,13 +6,13 @@ import java.util.Iterator; import java.util.Map; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ConcurrentHashMap; -import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import org.apache.log4j.Logger; import org.apache.thrift.TException; import org.openslx.bwlp.sat.util.Constants; import org.openslx.bwlp.sat.util.Formatter; +import org.openslx.bwlp.sat.util.GrowingThreadPoolExecutor; import org.openslx.bwlp.sat.util.PrioThreadFactory; import org.openslx.bwlp.thrift.iface.ImagePublishData; import org.openslx.bwlp.thrift.iface.InvocationError; @@ -31,7 +31,7 @@ public class SyncTransferHandler { private static final Logger LOGGER = Logger.getLogger(SyncTransferHandler.class); - private static final ThreadPoolExecutor transferPool = new ThreadPoolExecutor(1, + private static final GrowingThreadPoolExecutor transferPool = new GrowingThreadPoolExecutor(1, Constants.MAX_MASTER_UPLOADS + Constants.MAX_MASTER_DOWNLOADS, 1, TimeUnit.MINUTES, new ArrayBlockingQueue<Runnable>(1), new PrioThreadFactory("MasterTransferPool", Thread.NORM_PRIORITY - 3)); |