java中线程之间的通信：如果另一个线程完成则停止一个线程

Question

我怎样才能让一个线程只有在另一个线程也在运行时才运行，这意味着，如果我从一个线程中运行返回，那么我希望另一个也停止运行， 我的代码如下所示：

ClientMessageHandler clientMessagehandler = new ClientMessageHandler();
ServerMessageHandler serverMessagehandler = new ServerMessageHandler();
Thread thread1 = new Thread(serverMessagehandler);
Thread thread2 = new Thread(clientMessagehandler);
thread2.start();
thread1.start();

我想让thread1 在thread2 停止运行时停止运行。

编辑：检测thread2 何时停止运行以便停止thread1 运行，而不是如何停止thread1 运行 谢谢

Answer 1

这个最小的例子应该展示基本思想：

import java.io.*;
import java.util.concurrent.LinkedBlockingQueue;

public class Test {

    static LinkedBlockingQueue<String> msgBuf = new LinkedBlockingQueue<String>();
    static volatile boolean keepRunning = true;
    static Thread thread1, thread2;

    public static void main(String[] args) throws IOException {
        ClientMessageHandler clientMessagehandler = new ClientMessageHandler();
        ServerMessageHandler serverMessagehandler = new ServerMessageHandler();
        thread1 = new Thread(serverMessagehandler);
        thread2 = new Thread(clientMessagehandler);
        thread2.start();
        thread1.start();
    }

}

class ClientMessageHandler implements Runnable {
    public void run() {
        while (Test.keepRunning) {
            try {
                String msg = Test.msgBuf.take();
                System.out.println("Eating " + msg);
            } catch (InterruptedException ie) {
            }
        }
    }
}

class ServerMessageHandler implements Runnable {
    public void run() {
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        String in;
        try {
            while (!(in = br.readLine()).equals("quit")) {
                System.out.println("Feeding " + in);
                Test.msgBuf.offer(in);
            }
        } catch (IOException e) {
        }
        Test.keepRunning = false;
        Test.thread2.interrupt();
    }
}

Answer 2

编辑以澄清问题

我看到两个直接选项：

选项 1. 让 ClientMessageHandler 实现在 ServerMessageHandler 终止时终止它。这意味着客户端需要对服务器线程的引用。

public class ClientMessageHandler implements Runnable {
    Thread serverThread;
    public ClientMessageHandler(Thread srvThread) {
        this.serverThread = srvThread;
    }
    public void run() {
        try {
            while (true) { ... }
        } finally {
           serverThread.interrupt();
        }
   }
}

选项 2. 使用 thread2.join() 或 CountDownLatch 等待线程 2 终止。当控制从连接（或CountDownLatch#await()）返回时。

ClientMessageHandler clientMessagehandler = new ClientMessageHandler();
ServerMessageHandler serverMessagehandler = new ServerMessageHandler();
Thread thread1 = new Thread(serverMessagehandler);
Thread thread2 = new Thread(clientMessagehandler);
thread2.start();
thread1.start();

thread2.join(); //blocks until the client terminates
thread1.interrupt();

确保在 thread1 的 run 方法中，您有一些逻辑位置可以检查中断状态 (Thread#isInterrupted()) 并决定终止。此外，您必须注意正确处理InterruptedException，并终止或重置中断标志。

Answer 3

Thread 只会在 run() 方法返回时停止。 Thread#interrupt() 仅表示已发出中断请求。您仍然必须相应地在 run() 方法中编写代码，以便它定期检查 Thread#isInterrupted() 并进行相应处理。例如。在Thread 正在执行的每个任务单元上检查它，或者在附加某种progresslistener 时检查每个特定的进度。