java – 无法停止使用ExecutorService启动的任务
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了java – 无法停止使用ExecutorService启动的任务,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含2737字,纯文字阅读大概需要4分钟。
内容图文
![java – 无法停止使用ExecutorService启动的任务](/upload/InfoBanner/zyjiaocheng/731/07e2d92b174049c9a841d50cb5f7806c.jpg)
对不起,我必须打开一个新线程来描述这个问题.
今天早上我问this question,有一些回复,但我的问题仍未解决.
这次我将附加一些可运行的代码(简化但有相同的问题),以便您重现问题:
public class ThreadPoolTest {
public static void main(String[] args) throws Exception {
final ExecutorService taskExecutor = Executors.newFixedThreadPool(5);
Future<Void> futures[] = new Future[5];
for (int i = 0; i < futures.length; ++i)
futures[i] = startTask(taskExecutor);
for (int i = 0; i < futures.length; ++i)
System.out.println("futures[i].cancel(true): " + futures[i].cancel(true));
System.out.println("Cancel DONE.");
taskExecutor.shutdown();
}
private static Future<Void> startTask(final ExecutorService taskExecutor) {
Future<Void> f = taskExecutor.submit(new Callable<Void>() {
public Void call() throws Exception {
try {
downloadFile(new URI("https://stackoverflow.com"));
while(true) {
System.out.println(Thread.currentThread().getName() + ": " + Thread.currentThread().isInterrupted());
if(Thread.currentThread().isInterrupted())
break;
}
} catch (Exception ex) {
ex.printStackTrace();
}
return null;
}
});
return f;
}
private static void downloadFile (final URI uri) throws Exception {
// if(true) return;
Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort());
return;
}
}
上面的代码很可能被困在一个无限循环中(你可能希望多次运行代码来见证我看到的内容),正如你在main方法中看到的那样,我称之为future [i] .cancel(true)for所有的任务,我不知道为什么会这样,这已经让我折磨了一天多.
对你的帮助表示感谢.
解决方法:
我玩过你的代码,并注意到在创建套接字之前线程的中断状态有时是真的,之后是假的.
我试过打断一个线程并调用Socket构造函数,然后线程总是保持中断状态.我也尝试删除线程池的关闭,问题继续发生.
然后我尝试使用5个不同的URI,而不是总是相同的URI.问题从未发生过.
所以我写了这个简单的程序,表明线程池不是罪魁祸首,但套接字是:
public static void main(String[] args) throws Exception {
final URI uri = new URI("https://stackoverflow.com");
for (int i = 0; i < 5; i++) {
Runnable r = new Runnable() {
@Override
public void run() {
Thread.currentThread().interrupt();
System.out.println(Thread.currentThread().isInterrupted());
try {
Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort());
}
catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(Thread.currentThread().isInterrupted());
}
};
new Thread(r).start();
}
}
实际上,当5个线程创建到同一主机和端口的套接字时,其中4个线程的中断状态被清除.
然后我尝试同步套接字创建(在一个锁上,但我猜你可能每个主机/端口使用一个锁):
synchronized(lock) {
try {
Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort());
}
catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
和TADA ……问题消失了.我会在Oracle上打开一个错误来表示问题.
内容总结
以上是互联网集市为您收集整理的java – 无法停止使用ExecutorService启动的任务全部内容,希望文章能够帮你解决java – 无法停止使用ExecutorService启动的任务所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。