如何超时一个线程

我想在一段固定的时间内运行一个线程。 如果在这段时间内没有完成,我想要杀死它,抛出一些异常,或以某种方式处理它。 如何做呢?

我从这个线程中发现的一种方法是在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以确定发生了什么。

链接地址: http://www.djcxy.com/p/30797.html

上一篇: How to timeout a thread

下一篇: Creating/Opening Events in C++ and checking if they are fired