Java ExecutorService提交任务流程

在Java中，ExecutorService是一个接口，它提供了一种将任务提交给线程池执行的方式。使用ExecutorService可以更有效地管理线程资源，避免线程创建和销毁的开销，并提供更好的性能。以下是使用ExecutorService提交任务的流程：

1. 创建ExecutorService实例

首先，你需要创建一个ExecutorService实例。通常使用Executors工具类来创建不同类型的线程池。

ExecutorService executorService = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池

2. 定义任务

定义一个实现了Runnable或Callable接口的任务。

使用Runnable接口

class MyTask implements Runnable {
    @Override
    public void run() {
        System.out.println("Task is running on thread: " + Thread.currentThread().getName());
    }
}

使用Callable接口

class MyCallableTask implements Callable<Integer> {
    @Override
    public Integer call() throws Exception {
        System.out.println("Task is running on thread: " + Thread.currentThread().getName());
        return 42;
    }
}

3. 提交任务

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

提交Runnable任务

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

提交Callable任务

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

4. 处理任务结果

如果任务是Callable类型，可以通过Future对象获取任务的执行结果。

try {
    Integer result = future.get(); // 获取任务结果
    System.out.println("Task result: " + result);
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
}

5. 关闭ExecutorService

当所有任务都完成后，应该关闭ExecutorService以释放资源。

executorService.shutdown(); // 平滑关闭，不再接受新任务，但会等待已提交的任务完成
// 或者
executorService.shutdownNow(); // 立即关闭，尝试停止所有正在执行的任务

示例代码

以下是一个完整的示例代码，展示了如何使用ExecutorService提交和处理任务：

import java.util.concurrent.*;

public class ExecutorServiceExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        // 提交Runnable任务
        Future<?> future1 = executorService.submit(new MyTask());
        Future<?> future2 = executorService.submit(new MyTask());

        // 提交Callable任务
        Future<Integer> future3 = executorService.submit(new MyCallableTask());

        // 处理任务结果
        try {
            Integer result = future3.get();
            System.out.println("Callable task result: " + result);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }

        // 检查任务是否完成
        if (future1.isDone() && future2.isDone()) {
            System.out.println("All tasks are done.");
        }

        // 关闭ExecutorService
        executorService.shutdown();
    }

    static class MyTask implements Runnable {
        @Override
        public void run() {
            System.out.println("Task is running on thread: " + Thread.currentThread().getName());
        }
    }

    static class MyCallableTask implements Callable<Integer> {
        @Override
        public Integer call() throws Exception {
            System.out.println("Callable task is running on thread: " + Thread.currentThread().getName());
            return 42;
        }
    }
}

通过以上步骤，你可以有效地使用ExecutorService来管理和执行多线程任务。