ExecutorService任务提交流程

ExecutorService 是 Java 并发包 java.util.concurrent 中的一个接口，它提供了一种将任务提交给线程池执行的方式。以下是使用 ExecutorService 提交任务的流程：

1. 创建 ExecutorService 实例： 首先，你需要创建一个 ExecutorService 的实例。这通常通过调用 Executors 工厂方法来完成，例如：

ExecutorService executorService = Executors.newFixedThreadPool(10);

这里创建了一个固定大小为 10 的线程池。

2. 创建 Runnable 或 Callable 任务： 接下来，你需要创建一个实现了 Runnable 或 Callable 接口的任务。Runnable 任务没有返回值，而 Callable 任务可以返回一个结果。

Runnable task = () -> {
    // 任务逻辑
};

// 或者

Callable<Integer> callableTask = () -> {
    // 任务逻辑
    return 42;
};

3. 提交任务： 使用 ExecutorService 的 submit() 方法将任务提交给线程池。对于 Runnable 任务，直接传递任务对象；对于 Callable 任务，传递任务对象并接收一个 Future 对象，该对象可用于获取任务的执行结果。

// 提交 Runnable 任务
Future<?> future = executorService.submit(task);

// 提交 Callable 任务
Future<Integer> callableFuture = executorService.submit(callableTask);

4. 执行任务： 线程池中的线程会自动执行提交的任务。对于 Runnable 任务，线程会直接调用其 run() 方法；对于 Callable 任务，线程会调用其 call() 方法，并返回一个 Future 对象。

5. 获取任务结果（仅适用于 Callable 任务）： 如果你提交了一个 Callable 任务并获得了 Future 对象，你可以使用它来获取任务的执行结果、检查任务是否完成或取消任务。

// 检查任务是否完成
boolean isDone = callableFuture.isDone();

// 获取任务结果（如果任务已完成）
Integer result = callableFuture.get();

// 取消任务（如果尚未开始执行）
callableFuture.cancel(true);

6. 关闭 ExecutorService： 当你不再需要 ExecutorService 时，应该调用其 shutdown() 方法来优雅地关闭线程池。这将阻止新任务被提交，并允许已提交的任务完成执行。

executorService.shutdown();

如果你需要在关闭线程池之前强制终止所有正在执行的任务，可以使用 shutdownNow() 方法。但请注意，这可能会导致正在执行的任务被中断，并且未完成的任务可能不会被执行。

以上就是使用 ExecutorService 提交任务的基本流程。