Java ExecutorService任务提交流程

Java中的ExecutorService是一个接口，它提供了一种将任务提交给线程池执行的方式。使用ExecutorService可以更方便地管理线程的生命周期，提高系统性能和稳定性。以下是使用ExecutorService提交任务的流程：

1. 创建一个实现了Runnable或Callable接口的任务类。Runnable接口的run()方法没有返回值，而Callable接口的call()方法有返回值。

class MyTask implements Runnable {
    @Override
    public void run() {
        // 任务逻辑
    }
}

或者

class MyCallableTask implements Callable<Integer> {
    @Override
    public Integer call() throws Exception {
        // 任务逻辑
        return 42;
    }
}

2. 创建一个ExecutorService实例。通常使用Executors类的静态方法来创建，例如：

ExecutorService executorService = Executors.newFixedThreadPool(5);

这里创建了一个固定大小的线程池，最多可以同时执行5个任务。

3. 使用ExecutorService的submit()方法提交任务。对于Runnable任务，使用submit()方法接收一个Runnable参数；对于Callable任务，使用submit()方法接收一个Callable参数。

Future<?> future = executorService.submit(new MyTask());

或者

Future<Integer> future = executorService.submit(new MyCallableTask());

submit()方法返回一个Future对象，可以用来获取任务的执行结果或取消任务。

4. 如果需要获取任务的执行结果，可以调用Future对象的get()方法。如果任务尚未完成，get()方法会阻塞等待。

try {
    Object result = future.get();
    // 处理结果
} catch (InterruptedException | ExecutionException e) {
    // 处理异常
}

5. 当所有任务都执行完毕后，调用ExecutorService的shutdown()方法关闭线程池。这将不再接受新的任务，但会等待已提交的任务执行完毕。

executorService.shutdown();

6. 如果需要立即关闭线程池，可以使用shutdownNow()方法。这将尝试停止所有正在执行的任务，并返回尚未开始执行的任务列表。

List<Runnable> remainingTasks = executorService.shutdownNow();

总结一下，使用ExecutorService提交任务的流程包括：创建任务类、创建ExecutorService实例、提交任务、获取执行结果（可选）、关闭线程池。这样可以更方便地管理线程和任务，提高系统性能和稳定性。