ExecutorService 由多个线程执行单个任务 n 次（n 线程“竞赛”）答案

【问题标题】：ExecutorService to execute a single task n times by multiple threads (n thread "races")ExecutorService 由多个线程执行单个任务 n 次（n 线程“竞赛”）
【发布时间】：2020-09-07 15:14:22
【问题描述】：

我需要由多个线程执行单个任务，这样当第一个线程完成时，在任何其他线程完成之前，所有线程都会停止并重新启动相同的任务。这应该执行 n 次。

我的尝试是使用Callable<V> 和invokeAny() 方法（这就是我使用集合的原因），但不确定如何实现目标。

ExecutorService executor = Executors.newFixedThreadPool(10);
Callable<String> task = () -> {
    someTask();
    return "";
};
Set<Callable<String>> tasks = new HashSet<>();
IntStream.range(0, n).forEach(i -> {
    tasks.add(task);
    executor.submit(task);
});

如何完成这个？还是有更好的解决方案？

【问题讨论】：

executor.submit(task); 将返回一个Future<String>。您只需要等待所有这些都完成。
谢谢，但仍不确定。他们应该在第一个任务完成后重新开始任务，所以想知道发生这种情况时我将如何收到通知？我想到了一个循环来不断检查线程是否完成，但继续检查似乎有点浪费。不知道如何在这里使用Future<String> 结果。
“当第一个线程结束，其他线程结束前，所有线程都停止，重新开始同一个任务”每个线程都“进行一次尝试”，当一个成功时，其他线程无关紧要，应该停止吗？
是的，就是这样
您是否认为如果您并行运行多个并选择最快的一个，您会比一次运行它节省时间吗？这里的用例是什么？

标签： java multithreading executorservice callable

【解决方案1】：

这里有一个建议：

class Task implements Callable<Integer> {

    private final static Random RND = new Random();

    @Override
    public Integer call() throws Exception {
        try {
            // Work on task for a random duration
            Thread.sleep(RND.nextInt(5000));
        } catch (InterruptedException e) {
            System.err.println("I was interrupted."
                    + "Someone else probably solved the task before me.");
            return -1;
        }

        // Return some dummy value
        return RND.nextInt();
    }
}

class Scratch {
    public static void main(String[] args) throws InterruptedException {

        final int numWorkers = 3; // number of tasks to run in parallel

        ExecutorService executor = Executors.newFixedThreadPool(numWorkers);

        // Solve task 5 times. (Change it to while (true) { ...} if you like.)
        for (int i = 0; i < 5; i++) {

            CompletionService<Integer> completionService =
                    new ExecutorCompletionService<>(executor);

            Future<?>[] futures = new Future<?>[numWorkers];
            for (int j = 0; j < numWorkers; j++) {
                futures[j] = completionService.submit(new Task());
            }

            Future<Integer> firstToComplete = completionService.take();

            try {
                Integer result = firstToComplete.get();
                System.err.println("We got a result: " + result);
            } catch (ExecutionException e) {
                // Should not happen. Future has completed.
            }

            // Cancel all futures (it doesn't matter that we're cancelling
            // the one that has already completed).
            for (int j = 0; j < numWorkers; j++) {
                futures[j].cancel(true);
            }
        }

        executor.shutdown();
    }
}

如果您正在解决的任务不响应中断，则将true 传递给cancel(...) 将无济于事。在这种情况下，我建议您进行以下更改：

在外部 for 循环中创建一个 AtomicBoolean done 变量。
将此传递给构造函数到Task 并将其保存在Task 的字段中。
在任务解决过程中，经常检查done标志，如果done是true则取消尝试。
不要在第一个结果进入后对任务调用cancel，而是将done设置为true并等待其他线程返回。

【讨论】：