如何在Java中使用ExecutorService为任务设置超时时间[重复]

Question

我有使用 ExecutorService 来安排任务的方法。我需要在一段时间后终止任务。如何指定这样的时间？

public String schedule(Callable<Object> task)
        {

            Future<Object> f = null;
            String status = null;
            try
            {
                f = service.submit(task);
                status = f.get(1, TimeUnit.SECONDS).toString();
            }
            catch (TimeoutException e)
            {
                status = "Waiting took too long.";
            }
            catch (Exception e)
            {
                 status = e.getMessage();
            }

            return f.toString();
        }

编辑： 我有一个进程应该在等待 x 时间以使资源可用后终止，而不是无限期地等待。

Answer 1

这个停止执行行为应该由任务本身来实现。您可以尝试强制停止线程，但这会导致死锁问题。

您应该让任务实现超时逻辑，以便它们可以以适当的方式自行关闭。

---

这是一个等待资源的任务的基本示例：

@Override
public Object call() throws Exception { // In a Callable<Object>
    long startTime = System.currentTimeMillis();
    while(System.currentTimeMillis() - startTime < 5000) { // wait for max 5 seconds.
        if(resource.isAvailable()) {
            // Do something with the resource
            return someValue;
        }
    }

    throw new TimeoutException("Resource could not be acquired");
}