JavaソケットリスナーCPU負荷100％

Question

リモートソケットを継続的に聴いて、指定された入力に対して反応する必要があります。

public void listen(String ip, int port) { 
    try (
     Socket socketListener = new Socket(ip, port); 
     BufferedReader portReader = new BufferedReader(new InputStreamReader(socketListener.getInputStream())); 
    ) { 
     while (true) { 
     while (!portReader.ready()) { 
      // Wait for next PORT message 
     } 

     Logger.log(LogComponent.SOCKET, "Event received"); 
     } 
    } 
    } 

私は上記のコードが100％のCPU負荷を使用しているので非常に間違っていますか？

デバッグ中は、while-！portreader-loopが悪意のある人であることがわかります。しかし、私が見つけた例のほとんどは同じようにそれをやっています。あなたのコメントを考慮し

EDIT＃1

私は今のソリューションを次ています

try { 

    Socket SocketListener = new Socket(ip, port); 
    BufferedReader portReader = 
    new BufferedReader(
     new InputStreamReader(SocketListener.getInputStream()) 
    ); 

    // We do not use common while(true)-pattern for reading the input. 
    // Instead, we check for new input 3 times a second. 
    ScheduledExecutorService executor = Executors.newScheduledThreadPool(10); 
    executor.scheduleAtFixedRate(() -> { 
    try { 
     processInput(portReader); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
    }, 0, 333, TimeUnit.MILLISECONDS); 

} catch (Exception exception) { 
    exception.printStackTrace(); 
} 

そしてprocessInput(0)は今、行動を行っています。 これは単純にThread.sleep（）を使用するよりもパフォーマンスが向上しますが、理由はわかりません。

このアプローチを使用する場合：コードがソケットからメッセージをいくつか見逃している可能性がありますか？私はその間隔の間に意味する？

Answer 1

問題は、while（true）内のコードがすべてのCPUを消費していることです。

public void listen(String ip, int port) { 
    try (Socket socketListener = new Socket(ip, port); 
    BufferedReader portReader = new BufferedReader(new InputStreamReader(socketListener.getInputStream()));) { 
     while (true) { 
      while (!portReader.ready()) { 
       // Wait for next PORT message 
       try { 
        Thread.sleep(1); 
       } catch(InterruptedException e) { 
        //handle InterruptedException 
       } 
      } 
      Logger.log(LogComponent.SOCKET, "Event received"); 
     } 
    } 
} 

Answer 2

それはwhileループ内の命令を処理しているためお使いのCPUがビジー状態である：のような単一の変更を行います。

これを避けるには、ソケットが接続されるのを待つ関数を使用する必要があります。着信接続を待っている場合は、Socket.accept()を使用してください。これにより、接続が確立されるまでスレッドがブロックされます（つまり、スレッドは実行のスケジュールが設定されません）。

Thread.sleep()はお勧めしません。これによりCPU使用率はやや低下しますが、CPUを不必要に消費し、遅延を招くことになります。これは悪い工学的実践です。

それ以外にも、非ブロッキングまたは非同期のI/Oを調べることができます。詳細についてはSee hereをご覧ください。