我想运行一个线程一段固定的时间。如果在那段时间内没有完成,我想杀死它,抛出一些异常,或者以某种方式处理它。怎么办?
我从 this thread 发现的一种方法 就是在 Thread 的 run() 方法中使用 TimerTask。
有没有更好的解决方案?
编辑:添加赏金,因为我需要一个更清晰的答案。下面给出的 ExecutorService 代码不能解决我的问题。为什么我应该在执行后 sleep() (一些代码 - 我无法处理这段代码)?如果代码完成了,sleep()被打断了,怎么会是timeOut呢?
需要执行的任务不在我的控制范围内。它可以是任何一段代码。问题是这段代码可能会陷入无限循环。我不希望这种情况发生。所以,我只想在一个单独的线程中运行该任务。父线程必须等到该线程完成并需要知道任务的状态(即它是否超时或发生了一些异常或是否成功)。如果任务进入无限循环,我的父线程会无限期地等待,这不是一个理想的情况。
最佳答案
确实宁愿使用ExecutorService
这里是 SSCCE 而不是 Timer
:
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)
block 中拦截超时。
更新:为了澄清概念上的误解,sleep()
不需要。它仅用于 SSCCE/演示目的。只需在 sleep()
的位置执行 your 长时间运行的任务即可。在您长时间运行的任务中,您应该检查线程是否不是 interrupted如下:
while (!Thread.interrupted()) {
// Do your long running task here.
}
关于java - 如何使线程超时,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/2275443/