Écouteur Java socket Charge CPU de 100%

Question

Je dois écouter en continu une prise distante et réagir sur une entrée donnée. Qu'est-ce que je fais si mal que le code ci-dessus utilise 100% de la charge de l'unité centrale?

Lors du débogage, je peux voir que la boucle while-! Portreader-loop est le malfaiteur. Mais la plupart des exemples que j'ai trouvés le font de la même manière.

EDIT # 1

Compte tenu de vos commentaires que j'ai la solution suivante en ce moment:

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(); 
} 

Et processInput(0) fait l'action maintenant. Cela se termine par de meilleurs résultats que l'utilisation de Thread.sleep() - même si je ne comprends pas pourquoi. Lors de l'utilisation de cette approche: Le code peut-il manquer certains messages du socket? Je veux dire pendant les intervalles?

Answer 1

Le problème est que votre code à l'intérieur de votre while (vrai) consomme tout le CPU. Faire un seul changement comme:

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

Votre CPU est occupé, car il est des instructions de traitement dans la boucle while. Pour l'éviter, vous devez utiliser une fonction qui attend que la prise soit connectée. Si vous attendez une connexion entrante, utilisez Socket.accept(). Cela bloquera le thread (c'est-à-dire que le thread ne sera pas programmé pour l'exécution) jusqu'à ce que la connexion soit établie. Ne pas utiliser Thread.sleep() comme d'autres l'ont suggéré.

Bien que cela réduise quelque peu l'utilisation du processeur, il continuera à brûler le processeur inutilement et à introduire une latence. C'est une mauvaise pratique d'ingénierie. En outre, vous pouvez vous intéresser aux E/S non bloquantes ou asynchrones. See here pour plus d'informations.