Java 如何使线程超时

Question

想在一个固定的时间内运行一个线程。如果未在该时间内完成，我想杀死它，抛出一些异常或以某种方式处理它。怎么做到呢？

我从该线程 了解到的一种方法是在该线程的run（）方法内使用TimerTask。

有没有更好的解决方案呢？

编辑：添加赏金，因为我需要一个更明确的答案。下面给出的ExecutorService代码无法解决我的问题。为什么在执行完某些代码后就进入sleep（）-我无法处理这段代码？如果代码完成并且sleep（）被中断，那怎么可能是超时呢？

需要执行的任务不在我的控制范围内。它可以是任何代码。问题在于这段代码可能会陷入无限循环。我不希望那样发生。因此，我只想在单独的线程中运行该任务。父线程必须等到该线程完成并且需要知道任务的状态（即，它是否超时还是发生某些异常，或者它是否成功）。如果任务进入无限循环，我的父线程将无限期地等待，这不是理想的情况。

Answer 1

的确使用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!";
    }
}

timeout在Future#get()方法中使用参数，例如将其增加到5，你将看到线程完成。你可以在catch (TimeoutException e)块中拦截超时。

更新：澄清一个概念的误解，将sleep()是不必需的。它仅用于SSCCE /演示目的。只要做你的长时间运行的任务就在那里发生的sleep()。在长时间运行的任务中，应检查线程是否未中断，如下所示：

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