线程中断

Question

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

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

现在，正如您所看到的，我首先启动每个线程并加入它们。我想知道的是"thread.interrupt()“是否做了我认为它做的事情。我已经创建了一个易失性布尔值"done“(缺省情况下为false )。我还有另一段代码，每个线程在文件中搜索某些内容。当找到某些东西时，我将boolean done设置为true。我希望这能阻止所有其他还没有完成的线程运行。

然而，有一种感觉告诉我，这并不像我所做的那么容易。因此，如果有人能告诉我我所做的是否正确-如果不是-这到底是什么，我将不胜感激。

Answer 1

我想知道的是，"thread.interrupt()“是否做了我认为的事情。

不，不是的。

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

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

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

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

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