executorserviceワーカーが別のスレッドで実行されていません

Question

私はnewFixedThreadPoolを使用して、着信要求を同時にサーバーソケットに配信しています。何らかの理由で、クライアントにサービスを提供するワーカークラスが別のスレッドで実行されていません。ソケットに複数のリクエストを送信すると、リクエストは同時に処理されるのではなく、順次処理されます。私はOpenJDK 1.8.0_77を実行しています。

これは私のメインクラスの抜粋です。

ExecutorService executorService = Executors.newFixedThreadPool(100); 
    ServerSocket serverSocket = new ServerSocket(5656); 

    while(true) { 
     Socket socket = serverSocket.accept(); 
     executorService.execute(new ConnectionHandler(socket)); 
    } 

これは私のワーカークラスです：

public class ConnectionHandler implements Runnable { 

    private Socket socket; 

    public ConnectionHandler(Socket socket) { 
     this.socket = socket; 
    } 

    public void run() { 

     try { 
      Thread.sleep(5000); 
     } catch (InterruptedException e1) { 
      e1.printStackTrace(); 
     } 

     BufferedReader reader = null; 
     PrintWriter writer = null; 
     try { 
     reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); 
     writer = new PrintWriter(socket.getOutputStream(), true); 

     while(true) { 
      String line = reader.readLine(); 
      if(line == null) break; 
      writer.println("Echo: " + line); 
     } 
     } catch (IOException e) { 
     throw new RuntimeException(e); 
     } finally { 
     try { 
      if(reader != null) reader.close(); 
      if(writer != null) writer.close(); 
     } catch (IOException e) { 
      throw new RuntimeException(e); 
     } 
     } 
    } 

    } 

Answer 1

問題はこの呼び出しである：

executorService.execute(new ConnectionHandler(socket)); 

execute方法がありますタスクが完了するまで呼び出し側のスレッドを強制的にブロックすることができます。また、呼び出し元のスレッドperfo実際の仕事。代わりに、これを実行します。

executorService.submit(new ConnectionHandler(socket)); 

これは、プール内のスレッドを使用してタスクを非同期に実行します。

Answer 2

申し訳ありませんが、私はコンピュータで良くありません。

問題は、ソケットにループ内の多くのメッセージをエコーし​​ていたことですが、echoコマンドはメッセージを順次送信し、次のメッセージを送信する前にすべてのメッセージが終了するのを待ちます。