如何超时一个线程
我想在一段固定的时间内运行一个线程。 如果在这段时间内没有完成,我想要杀死它,抛出一些异常,或以某种方式处理它。 如何做呢?
我从这个线程中发现的一种方法是在Thread的run()方法中使用TimerTask。
有没有更好的解决方案呢?
编辑:添加一个赏金,因为我需要一个更清晰的答案。 下面给出的ExecutorService代码不能解决我的问题。 为什么我应该在执行之后sleep()(某些代码 - 我没有处理这段代码)? 如果代码完成并且sleep()被中断,那怎么会是一个超时?
需要执行的任务不在我的控制之下。 它可以是任何一段代码。 问题是这段代码可能会遇到无限循环。 我不希望这种情况发生。 所以,我只想在一个单独的线程中运行该任务。 父线程必须等到该线程完成并需要知道任务的状态(即是否超时或发生了某种异常或是否成功)。 如果任务进入无限循环,我的父线程会一直等待,这不是一个理想的情况。
确实是使用ExecutorService
而不是Timer
,这里是一个SSCCE:
package com.stackoverflow.q2275443;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
public class Test {
public static void main(String[] args) throws Exception {
ExecutorService executor = Executors.newSingleThreadExecutor();
Future<String> future = executor.submit(new Task());
try {
System.out.println("Started..");
System.out.println(future.get(3, TimeUnit.SECONDS));
System.out.println("Finished!");
} catch (TimeoutException e) {
future.cancel(true);
System.out.println("Terminated!");
}
executor.shutdownNow();
}
}
class Task implements Callable<String> {
@Override
public String call() throws Exception {
Thread.sleep(4000); // Just to demo a long running task of 4 seconds.
return "Ready!";
}
}
在Future#get()
方法中使用timeout
参数稍微玩一下,例如将它增加到5,你会看到线程完成。 您可以拦截catch (TimeoutException e)
块中的超时。
更新:澄清概念误解, sleep()
不是必需的。 它仅用于SSCCE /演示目的。 还是做你的长期运行的任务权有适当的sleep()
在长时间运行的任务中,您应该检查线程是否不中断,如下所示:
while (!Thread.interrupted()) {
// Do your long running task here.
}
对于任何旧任务来说,没有100%可靠的方法来做到这一点。 这个任务必须铭记在心。
像ExecutorService
这样的核心Java库通过在工作线程上调用interrupt()
取消异步任务。 因此,例如,如果任务包含某种循环,则应在每次迭代中检查其中断状态。 如果任务正在进行I / O操作,则它们也应该是可以中断的,并且设置它可能会非常棘手。 无论如何,请记住代码必须主动检查中断; 设置中断不一定会做任何事情。
当然,如果你的任务是简单的循环,你可以在每次迭代时检查当前时间,并在指定的超时时间结束后放弃。 在这种情况下不需要工作者线程。
考虑使用ExecutorService的一个实例。 invokeAll()
和invokeAny()
方法都有timeout
参数。
当前线程会阻塞,直到方法完成(不确定是否需要),因为任务正常完成或达到超时。 您可以检查返回的Future
以确定发生了什么。
下一篇: Creating/Opening Events in C++ and checking if they are fired