changeset 465:cf0eb5b2b4d2 dispose

set priority I/O thread
author one
date Thu, 13 Nov 2014 17:57:37 +0900
parents 8434ff6a4b27
children 268b1280dc18
files src/main/java/alice/daemon/AcceptThread.java
diffstat 1 files changed, 4 insertions(+), 1 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/alice/daemon/AcceptThread.java	Wed Nov 05 22:41:43 2014 +0900
+++ b/src/main/java/alice/daemon/AcceptThread.java	Thu Nov 13 17:57:37 2014 +0900
@@ -30,9 +30,12 @@
                 String key = "accept" + counter;
                 IncomingTcpConnection incoming =
                         new IncomingTcpConnection(connection, DataSegment.get("local"), key);
+                incoming.setPriority(MAX_PRIORITY);
                 incoming.start();
                 DataSegment.setAccept(key, incoming);
-                new OutboundTcpConnection(connection).start();
+                OutboundTcpConnection outbound = new OutboundTcpConnection(connection);
+                outbound.setPriority(MAX_PRIORITY);
+                outbound.start();
                 counter++;
             } catch (IOException e) {
                 e.printStackTrace();