diff options
Diffstat (limited to 'src/main/java/org/openslx/filetransfer/Listener.java')
| -rw-r--r-- | src/main/java/org/openslx/filetransfer/Listener.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/main/java/org/openslx/filetransfer/Listener.java b/src/main/java/org/openslx/filetransfer/Listener.java index f7d4225..a0fc172 100644 --- a/src/main/java/org/openslx/filetransfer/Listener.java +++ b/src/main/java/org/openslx/filetransfer/Listener.java @@ -14,6 +14,7 @@ import javax.net.ssl.SSLContext; import javax.net.ssl.SSLServerSocketFactory; import org.apache.log4j.Logger; +import org.openslx.util.PrioThreadFactory; public class Listener { @@ -23,7 +24,8 @@ public class Listener private ServerSocket listenSocket = null; private Thread acceptThread = null; private final int readTimeoutMs; - private final ExecutorService processingPool = new ThreadPoolExecutor( 0, 8, 5, TimeUnit.MINUTES, new SynchronousQueue<Runnable>() ); + private final ExecutorService processingPool = new ThreadPoolExecutor( 0, 8, 5, TimeUnit.MINUTES, new SynchronousQueue<Runnable>(), + new PrioThreadFactory( "BFTP-Init" ) ); private static final byte CONNECTING_PEER_WANTS_TO_UPLOAD = 85; // hex - code 'U' = 85. private static final byte CONNECTING_PEER_WANTS_TO_DOWNLOAD = 68; // hex - code 'D' = 68. |