如何超时线程

问题:

我想运行一段线程一段固定的时间。如果在那段时间内没有完成,我想要杀死它,抛出一些异常,或者以某种方式处理它。怎么办?
this thread我想出的一种方式
是在Thread的run()方法中使用TimerTask。
有没有更好的解决方案呢?
 
编辑:添加一个赏金,因为我需要一个更清楚的答案。下面给出的ExecutorService代码没有解决我的问题。为什么我应该在执行后sleep()(一些代码 – 我没有处理这段代码)?如果代码完成并且sleep()被中断,那怎么可能是timeOut?
需要执行的任务不在我的控制之中。它可以是任何代码片段。问题是这段代码可能会遇到无限循环。我不希望发生这种情况。所以,我只想在一个单独的线程中运行该任务。父线程必须等到该线程完成并需要知道任务的状态(即是否超时或发生一些异常或成功)。如果任务进入无限循环,我的父线程将无限期地等待,这不是理想的情况。

回答:

确实使用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()。在长时间运行的任务中,您应该检查线程是否不是interrupted,如下所示:

while (!Thread.interrupted()) {
    // Do your long running task here.
}

 
 
Code问答: http://codewenda.com/topics/python/
Stackoverflow: How to timeout a thread

*转载请注明本文链接以及stackoverflow的英文链接

发表评论

电子邮件地址不会被公开。 必填项已用*标注

27 − 21 =