java - 两个线程在运行时如何通信？

Question

我一直在尝试自学并发，但遇到了一个问题。我知道两个 Java 线程可以通过 wait() 和 notify() 相互通信。然而，这需要一个线程处于非 Activity 状态并且基本上“只是闲置”直到另一个线程将其唤醒。

是否有可能让两个线程同时运行并且仍然让它们监听来自另一个线程的通知？这将通过并发技术或类似 ActionListener 的方式来实现吗？

例如，我正在测试的项目基本上是一个网格，不同的实体在不同的单元格中四处游荡。当两个实体碰巧进入同一个单元格时，我希望一个实体通知另一个实体并基于此发生一些不同的事情(例如，问候语:“你好!”)。但就目前而言，对于等待/通知范例，其中一个线程/实体必须简单地坐在一个单元格中等待另一个线程/实体进入；他们不能同时四处走动。

Answer 1

有几种方法可以在线程之间进行通信。使用最常见的方法，您可以使用实例变量在线程之间共享信息，但您必须注意只从一个线程写入或同步对共享变量的任何更新。或者，您可以使用专为线程间通信或在线程之间传递原始数据而设计的管道 I/O 流。一个线程将信息写入流，而另一个线程读取它。

下面是一个示例方法，该方法将从慢速网络连接读取输出并使用线程将其转储到 System.out。

    public void threads() throws IOException {
    final PipedOutputStream outputForMainThread = new PipedOutputStream();
    new Thread(new Runnable() {
        @Override
        public void run() {
            while(moreDataOnNetwork()) {
                byte[] data = readDataFromNetwork();
                try {
                    outputForMainThread.write(data);
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }).start();
    BufferedReader reader = new BufferedReader(new InputStreamReader(new PipedInputStream(outputForMainThread)));
    for(String eachLine = reader.readLine(); eachLine != null; eachLine = reader.readLine()) {
        System.out.println(eachLine);
    }
}

然而，这听起来几乎像是您想要一种事件回调机制，其中一个线程(您的用户界面线程)在另一个线程检测到特定条件时得到通知。根据您的平台，其中大部分内容已内置。例如，使用 Android，您可以有一个线程来确定网格实体是否已移动。它会向主用户界面线程发送更新以重新绘制屏幕。这样的更新可能类似于:

public void gridEntityDidUpdate(final Point fromLocation, final Point toLocation) {
    Activity activity = getMainActivity();
    activity.runOnUiThread(
            new Runnable() {
                @Override
                public void run() {
                    updateScreen(fromLocation, toLocation);
                    if(pointsAreCoincedent(fromLocation, toLocation)) {
                        System.out.println("Hello there!");
                    }
                }
            }
    );
}

private void updateScreen(Point fromLocation, Point toLocation) {
    //Update the main activity screen here
}

在这种情况下，您有一个后台线程计算出所有屏幕元素的位置，并在元素位置发生变化时通知主线程。有一种提取方法可以确定2个点是否重合或相同。