java - 线程中断

Question

所以我有一个关于java中线程的interrupt()方法的问题。这是我的一段代码:

threads.forEach(Thread::start);
threads.forEach(thread -> {
    try {
        thread.join();
        if (done){
            thread.interrupt();
        }
    } catch (InterruptedException e){
        e.printStackTrace();
    }
});

现在，如您所见，我首先启动每个线程并加入它们。我想知道的是“thread.interrupt()”是否按照我的想法进行。我创建了一个 volatile boolean 值“done”(默认情况下为 false)。我在某处还有另一段代码，每个线程在文件中搜索某些内容。当发现某些东西时，我将 boolean 值“done”设置为“true”。我希望这会阻止所有其他尚未完成的线程运行。

但是，有些事情告诉我，这并不像我想象的那么容易。因此，如果有人能告诉我我所做的是否正确 - 如果不正确 - 这到底是做什么的，我将不胜感激。

Answer 1

What I want to know is if "thread.interrupt()" does what I think it does.

不，事实并非如此。

假设您有两个线程在文件中搜索某些内容。当 thread2 发现该东西是什么，并将 done 设置为 true 时，主线程(您问题中的代码)可能仍在等待 thread1 终止，因为您在 thread1 上调用了 thread.join();，而 threads.forEach 并不并行运行。

主线程将阻塞在thread1.join()上，直到thread1也发现了这个事情，或者在没有找到任何东西的情况下完成，或者被第三个线程中断。

要实现您的预​​期目的，您必须为您创建的每个线程维护所有其他线程的引用，并在任何一个线程第一次发现结果时中断所有其他线程。

另一种方法是不为每个线程调用 join，而是忙于检查 volatile 标志 done，并在 done == true 时中断每个线程。

threads.forEach(Thread::start);
while (!done) {
    Thread.sleep(100);
}
threads.forEach(thread -> {
    try {
        thread.interrupt();
    } catch (InterruptedException e){
        e.printStackTrace();
    }
});