加入后Java线程卡住

Question

我有这个 Transmitter 类，它包含一个 BufferedReader 和一个 PrintWriter。这个想法是，在主类上，使用 Transmitter.receive() 和 Transmitter.transmit() 到主套接字。问题是：

 public void receive() throws Exception {
      // Reads from the socket
      Thread listener = new Thread(new Runnable() {
        public void run() {
          String res;

          try {
            while((res = input.readLine()) != null) {
              System.out.println("message received: " + res);

              outputMessage = (res);

            if (res.equals("\n")) {
              break;
            }
           }
        } catch (IOException e) {
          e.printStackTrace();
        }
      };
    });

    listener.start();
    listener.join();
  }

线程更改了“outputMessage”值，我可以使用辅助方法获得该值。问题是，没有加入，我的客户得到了 outputMessage，但我想在我的主类上多次使用它，如下所示：

trans1.receive();
while(trans1.getOutput() == null);
System.out.println("message: " + trans1.getOutput());

但是加入这个 system.out 永远不会执行，因为trans1.receive() 被卡住了......有什么想法吗？

编辑1：这里是发射器类https://titanpad.com/puYBvlVery

Answer 1

您可以发送\n；这并不意味着您会在 Java 代码中看到它。

正如Javadoc for BufferedReader.readLine()（强调我的）中所说：

（返回）包含行内容的字符串，不包括任何行终止符

所以"\n" 永远不会被退回。

Answer 2

这样做：

{
  Thread listener = new Thread(new Runnable() {
    public void run() {
      doSomeWork();
    };
  });

  listener.start();
  listener.join();
}

将创建一个新线程，然后等待它完成工作并完成。因此它或多或少与直接做一样：

doSomeWork();

新线程在这里没有任何实际用途。

另外，额外的线程引入了同步问题，因为在您的代码中您不能确保变量是同步的。

第三，你的线程在一个循环中不断地从输入中读取行，直到没有更多要读取的内容，除非另一方关闭流，否则它将阻塞 readLine() 调用。你在 getOutput() 中看到的将是一条随机线，恰好在你看的那一刻就在那里，下次你看它可能是同一行，或者是完全不同的行；有些行会被立即读取并忘记，而您不会从主线程中注意到它。

当您实际上需要从输入中获取新行消息时，您可以直接在主线程中调用 input.readLine()，您不需要额外的阅读器线程。您可以按照 yshavit 的建议将读取的消息存储到队列中，如果需要的话，例如出于性能原因，最好在消息可用时立即读取它们并将它们准备好在内存中。但是，如果您只需要一条一条地阅读消息，那么您只需在真正需要时调用 input.readLine() 即可。