Как обходить сканер проверить следующий элемент (если это имеет смысл)

Question

Я пытаюсь создать непрерывный поток, где сервер получает/отправляет сообщения от клиента, однако, когда я пытаюсь проверить, что следующий элемент застрял:

public void run() 
{ 
    try 
    { 
     try 
     { 
      ArrayList<Socket> connections = parent.getConnections(); 
      in = new Scanner(socket.getInputStream()); 

      while(true) 
      { 
       if(in.hasNextLine()) // Gets stuck here 
       { 
        String message = in.nextLine(); 
        System.out.println("Client said " + message); 
       } 
      } 
     } 

     finally 
     { 
      socket.close(); 
     } 
    } 

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

Как сделать цикл не застревают в указанной точке

Answer 1

Предполагая, что вы хотите быть в состоянии иметь дело с «линий», я бы, вероятно, начать с чего-то вроде этого:

public class SocketReader implements Runnable { 

    private final InputStream stream; 
    private final Queue<String> destination; 
    private volatile boolean active = true; 

    private SocketReader(InputStream stream, Queue<String> destination) { 
     this.stream = stream; 
     this.destination = destination; 
    } 

    public static SocketReader getReader(Socket toRead, Queue<String> destination) throws IOException { 
     return new SocketReader(toRead.getInputStream(), destination); 
    } 

    public void shutdown() { 
     active = false; 
    } 

    public void run() { 
     while(active) { 
      if (stream.hasNextLine() && active) { 
       final String line = stream.nextLine; 
       destination.add(line); 
      } 
     } 
     try { 
      stream.close(); 
     } catch (IOException e) { 
      // Log somewhere 
     } 
    } 
} 

Поместите это в свой поток (или как часть потока или пула исполнителей, действительно), и вы сделали остальную часть вашего приложения неблокирующимся в отношении этого кода. EXPECT это для блокировки при ожидании обновлений от stream.hasNextLine(). Вы даже можете поставить BlockingQueue, если вы не хотите активно опросить очередь, но обрабатываете обновления каким-либо другим способом.

Вы можете сделать что-то подобное для вывода:

public class QueuedPrinter implements Runnable { 

    private final Queue<String> input; 
    private final PrintStream destination; 
    private volatile boolean active; 

    public QueuedPrinter(Queue<String> input, PrintStream destination) { 
     this.input = input; 
     this.destination = destination; 
    } 

    public void shutdown() { 
     active = false; 
    } 

    public void run() { 
     while(active) { 
      final String line = input.poll(); 
      if (line != null && active) { 
       destination.println(line); 
      } 
     } 
    } 

} 

Пожалуйста, обратите внимание, что я не проверял это, и вы, возможно, придется настроить вещи немного для других проверяемых исключений. Вероятно, вам нужно добавить дополнительный код проверки ошибок (наводит на мысль о нулевой обработке). Кроме того, это не полностью threadsafe, но, вероятно, будет «достаточно хорошим» для большинства целей.