如何使线程超时

timeout timer multithreading java

2022-08-31 05:21:54

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

正如我从这个线程中发现的那样，一种方法是在 Thread 的 run（）方法中使用 TimerTask。

有没有更好的解决方案？

编辑：添加赏金，因为我需要一个更清晰的答案。下面给出的执行器服务代码不能解决我的问题。为什么我应该在执行后 sleep（）（一些代码 - 我没有处理这段代码）？如果代码完成并且 sleep（）被中断，这怎么可能是超时？

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

答案 1

实际上，宁愿使用 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（） 方法中稍微玩一下参数，例如，将其增加到 5，你会看到线程完成。您可以截获块中的超时。timeoutcatch (TimeoutException e)

更新：澄清一个概念上的误解，不是必需的。它仅用于 SSCCE/演示目的。只需在那里执行长时间运行的任务即可代替。在长时间运行的任务中，您应该检查线程是否未中断，如下所示：sleep()sleep()

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

答案 2

对于任何旧任务，没有100%可靠的方法来执行此操作。在编写任务时必须牢记这种能力。

核心 Java 库（如在工作线程上使用 interrupt（） 调用取消异步任务）。因此，例如，如果任务包含某种循环，则应在每次迭代时检查其中断状态。如果任务正在执行 I/O 操作，它们也应该是可中断的，并且设置它可能很棘手。在任何情况下，请记住，代码必须主动检查中断;设置中断不一定能执行任何操作。ExecutorService

当然，如果你的任务是一些简单的循环，你可以在每次迭代时检查当前时间，并在指定的超时时间过去时放弃。在这种情况下，不需要工作线程。