如何在java中重复运行多个任务并在一定时间后停止它

Question

我在这里和那里看到了我的答案的一部分，但不是完整的。

我知道如果你想同时运行多个任务，你想使用 Thread 和 Runnable 实现

我看到如果你想运行这样的重复性任务，你可以使用ScheduledExecutorService：

Runnable helloRunnable = () -> System.out.println("Hello world " + LocalDateTime.now().toLocalTime().toString());
ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
executor.scheduleAtFixedRate(helloRunnable, 0, 10, TimeUnit.SECONDS);

但这只是运行一个线程，并且没有方法或参数在一定时间后杀死进程

我想做的是每 10 秒并行运行 5 次相同的任务，持续 10 分钟

---

编辑

如果未来的人对这里的完整示例感兴趣，那就是：

public static void main(String[] args) {
    Runnable helloRunnable = () -> System.out.println("Hello world " + LocalDateTime.now().toLocalTime().toString());
    Runnable testRunnable = () -> System.out.println("Test runnable " + LocalDateTime.now().toLocalTime().toString());

    List<Runnable> taskList = new ArrayList<>();
    taskList.add(helloRunnable);
    taskList.add(testRunnable);

    ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();

    List <ScheduledFuture<?>> promiseList = new ArrayList<>();
    for (Runnable runnable : taskList) {
        ScheduledFuture<?> promise = executor.scheduleAtFixedRate(runnable, 0, 1, TimeUnit.SECONDS);
        promiseList.add(promise);
    }

    List <Runnable> cancelList = new ArrayList<>();
    for (ScheduledFuture<?> promise : promiseList) {
        Runnable cancelRunnable = () -> {
            promise.cancel(false);
            executor.shutdown();
        };
        cancelList.add(cancelRunnable);
    }

    List <ScheduledFuture<?>> canceledList = new ArrayList<>();
    for (Runnable runnable : cancelList){
        ScheduledFuture<?> canceled = executor.schedule(runnable, 10, TimeUnit.SECONDS);
        canceledList.add(canceled);
    }
}

Answer 1

TL;DR：安排另一个任务以取消第一个任务。

首先，不要忽略返回值 - 这是养成的坏习惯，停止这样做并练习不这样做。 ScheduledExecutorService.scheduleAtFixedRate 方法返回 ScheduledFuture<?> - 这允许您取消任务！

因此，在1 分钟内每10 秒运行一次任务：

final Runnable helloRunnable = () -> System.out.println("Hello world " + LocalDateTime.now().toLocalTime().toString());
final ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
final ScheduledFuture<?> promise = executor.scheduleAtFixedRate(helloRunnable, 0, 10, TimeUnit.SECONDS);
final ScheduledFuture<Boolean> canceller = executor.schedule(() -> promise.cancel(false), 1, TimeUnit.MINUTES);

---

要注意的另一件事是，如果您从未在 Future 上调用 get，您将永远不知道任务是否失败 - 这意味着您需要 另一个 Thread 等待 @987654331 @ 以便在抛出 Exception 时立即知道出现问题。

那么问题是who monitors the monitoring threads。因此，如果您想要一些健壮的东西，您很快就会发现自己重新实现了一个任务调度库。

---

还要注意有用的实用方法Executors.newSingleThreadScheduledExecutor()。