如何用ExecutorService监听首个完成任务并取消其余任务

是的，你当前的写法确实已经错过取消其余任务的时机了。因为executor.invokeAll(tasks)方法会一直阻塞到所有任务执行完毕——不管任务是成功返回结果、抛出异常还是被取消，只有等所有任务都结束后，invokeAll才会返回Future列表。这时候你再去遍历Future，所有任务都已经运行完成，取消操作根本起不到任何作用。

正确实现方案 #

要实现"获取首个符合要求的成功结果后，立即取消其余未完成任务"的需求，不能使用invokeAll，需要逐个提交任务并主动轮询任务状态，具体代码如下：

List<Callable<String>> tasks = new ArrayList<>();
for (String id : ids) {
    tasks.add(() -> hitEndpoint(id));
}

// 逐个提交任务，保存所有Future实例
List<Future<String>> futures = new ArrayList<>();
for (Callable<String> task : tasks) {
    futures.add(executor.submit(task));
}

String targetResult = null;
try {
    for (Future<String> future : futures) {
        // 可根据需求添加超时时间，避免单个任务卡住流程：future.get(5, TimeUnit.SECONDS)
        String result = future.get();
        // 注意用equals比较字符串，不要用==
        if ("apple".equals(result)) {
            targetResult = result;
            break;
        }
    }
} catch (InterruptedException | ExecutionException e) {
    // 处理任务中断或执行异常
    e.printStackTrace();
} finally {
    // 取消所有未完成的任务
    for (Future<String> future : futures) {
        if (!future.isDone()) {
            // true表示中断正在运行的任务，前提是hitEndpoint方法能响应中断
            future.cancel(true);
        }
    }
}

// 后续处理目标结果
if (targetResult != null) {
    System.out.println("获取到目标结果：" + targetResult);
}

注意事项 #

• 字符串比较必须用equals()，不能用==，否则会因为引用不同导致匹配失败
• cancel(true)会向正在运行的线程发送中断信号，但hitEndpoint方法需要支持响应中断——比如方法内的网络请求、睡眠等阻塞操作，要正确处理InterruptedException，否则任务可能无法立即停止
• 建议给future.get()添加超时时间，避免单个任务执行过久导致整个流程卡住

内容的提问来源于stack exchange，提问作者luckysing_noobster