gpt4 book ai didi

java - 线程中断

转载 作者:行者123 更新时间:2023-12-01 17:45:43 25 4
gpt4 key购买 nike

所以我有一个关于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”。我希望这会阻止所有其他尚未完成的线程运行。

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

最佳答案

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();
}
});

关于java - 线程中断,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60868849/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com