Estoy implementando un programa Transfer Server que toma mensajes de los clientes (a través de la entrada de la consola) y luego los reenvía a algún tipo de buzón.

Para permitir la recepción simultánea de varios mensajes por diferentes clientes, primero creé una clase que implementa la interfaz Runnable . Cada una de las instancias de esta clase manejará la comunicación con exactamente un cliente:

 public class ClientConnection implements Runnable { //... //... @Override public void run() { try { // prepare the input reader and output writer BufferedReader reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); PrintWriter writer = new PrintWriter(clientSocket.getOutputStream(), true); Message message = new Message(); String request = ""; // read client requests while ((request = reader.readLine()) != null) { System.out.println("Client sent the following request: " + request); String response; if (request.trim().equals("quit")) { writer.println("ok bye"); return; } response = message.parseRequest(request); if (message.isCompleted()) { messagesQueue.put(message); message = new Message(); } writer.println(response); } } catch (SocketException e) { System.out.println("ClientConnection: SocketException while handling socket: " + e.getMessage()); } catch (IOException e) { throw new UncheckedIOException(e); } catch (InterruptedException e) { System.out.println("Client Connection was interrupted!"); e.printStackTrace(); } finally { if (clientSocket != null && !clientSocket.isClosed()) { try { clientSocket.close(); } catch (IOException ignored) {} } } } }

Tengo un subproceso principal que es responsable de iniciar y administrar todos los ejecutables de ClientConnection:

 @Override public void run() { clientConnectionExecutor = (ThreadPoolExecutor) Executors.newCachedThreadPool(); while (true) { Socket clientSocket; try { // wait for a Client to connect clientSocket = serverSocket.accept(); ClientConnection clientConnection = new ClientConnection(clientSocket, messagesQueue); clientConnectionExecutor.execute(clientConnection); } catch (IOException e) { // when this exception occurs, it means that we want to shut down everything clientConnectionExecutor.shutdownNow(); // force terminate all ClientConnections return; } } }

Ahora, de acuerdo con esta pregunta de Stackoverflow , hubiera esperado que tan pronto como shutdownNow(); se está llamando, se lanzaría una InterruptedException dentro de mi método ClientConnection.run() , y allí, debería imprimir Client Connection was interrupted! . Pero esto no sucede, por lo que parece que nunca se alcanza la cláusula catch, el bucle de lectura de entrada simplemente continúa.

Leí en otra pregunta de Stackoverflow que esto podría estar relacionado con alguna otra línea de código dentro del bloque que parece estar consumiendo la excepción InterruptedException , pero no había ninguna información particular sobre qué línea de código podría hacer eso. Así que estoy agradecido por cualquier pista.

Editar: resulta que tan pronto como salgo manualmente del ciclo escribiendo "salir" en el cliente, el ciclo se cerrará y luego, Client Connection was interrupted! será impreso. Entonces, de alguna manera, la excepción parece ignorarse mientras el ciclo se está ejecutando y solo se maneja después.