Java 中线程池怎么提交 Callable 任务管理返回值-java教程-PHP中文网

java线程池通过submit(callable)提交有返回值任务并返回future，调用get()阻塞获取结果或异常，推荐使用带超时的get避免无限等待；批量任务可用invokeall统一提交与收集；需及时shutdown线程池并合理处理future资源。

java 中线程池怎么提交 callable 任务管理返回值

Java 线程池提交 Callable 任务，核心是用 ExecutorService 的 submit() 方法，它会返回一个 Future 对象，用于获取异步执行结果、判断完成状态或主动取消任务。

用 submit(Callable) 获取 Future 并取返回值

Callable 和 Runnable 的关键区别在于：前者有返回值且可抛出受检异常。线程池不支持直接执行 Callable，但 submit() 方法专为此设计：

调用 executor.submit(myCallable) 后立即返回 Future<t></t>，不阻塞当前线程
Future.get() 是阻塞操作，会等待任务完成并返回结果；若任务抛异常，get() 会包装成 ExecutionException 抛出
建议配合超时使用 get(long timeout, TimeUnit unit)，避免无限等待

实际代码示例（带异常和超时处理）

比如计算一个耗时的阶乘：

ExecutorService executor = Executors.newFixedThreadPool(2);
Callable<biginteger> task = () -> {
    Thread.sleep(1000);
    return factorial(10);
};

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

try {
    BigInteger result = future.get(3, TimeUnit.SECONDS); // 最多等3秒
    System.out.println("结果：" + result);
} catch (TimeoutException e) {
    System.out.println("任务超时，已取消");
    future.cancel(true); // 中断正在执行的线程
} catch (ExecutionException e) {
    System.err.println("任务执行出错：" + e.getCause());
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
} finally {
    executor.shutdown();
}</biginteger></biginteger>