java ExecutorService怎样提交任务

在 Java 中，ExecutorService 是 java.util.concurrent 包提供的线程池接口，用来提交和执行任务。提交任务主要有以下几种方式和对应方法。

一、常见提交任务的方法

1. execute(Runnable) —— 无返回值

用于提交 不需要返回结果 的任务。

ExecutorService executor = Executors.newFixedThreadPool(2);

executor.execute(() -> {
    System.out.println("任务执行中");
});

特点：

• 只接受 Runnable
• 无法获取执行结果
• 无法感知任务是否抛异常（异常会直接打印）

2. submit(Runnable) —— 有 Future，但结果为 null

Future<?> future = executor.submit(() -> {
    System.out.println("Runnable 任务");
});

• 可通过 future.get() 判断是否执行完成
• get() 返回 null

3. submit(Callable<T>) —— 有返回值（最常用）

用于需要返回结果的任务。

Callable<String> task = () -> {
    return "任务结果";
};

Future<String> future = executor.submit(task);

String result = future.get(); // 阻塞等待结果

4. submit(Runnable, T result) —— 自定义返回结果

Future<String> future = executor.submit(() -> {
    System.out.println("执行任务");
}, "完成");

String result = future.get(); // 返回 "完成"

二、批量提交任务

invokeAll（等待所有任务完成）

List<Callable<String>> tasks = List.of(
    () -> "任务1",
    () -> "任务2"
);

List<Future<String>> futures = executor.invokeAll(tasks);

invokeAny（只要有一个完成就返回）

String result = executor.invokeAny(tasks);

三、获取任务结果（Future）

Future<String> future = executor.submit(() -> "结果");

try {
    String r = future.get(); // 阻塞
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
}

四、关闭线程池（很重要）

executor.shutdown(); // 等待已有任务执行完
// executor.shutdownNow(); // 立即中断

五、完整示例

ExecutorService executor = Executors.newFixedThreadPool(2);

Future<Integer> future = executor.submit(() -> {
    Thread.sleep(1000);
    return 10;
});

System.out.println(future.get());

executor.shutdown();

总结

如果你愿意，我也可以讲 线程池参数配置 或 Spring 中如何使用线程池。