使用@Async时，调用的是ThreadPoolTaskExecutor的submit方法还是executor

时间: 2023-10-31 15:38:48 浏览: 127

简单谈谈ThreadPoolExecutor线程池之submit方法

"ThreadPoolExecutor线程池之submit方法详解" 在 Java 中，ThreadPoolExecutor 是一个非常重要的线程池实现类，它提供了多种方式来执行任务，其中 submit 方法是其中一个重要的方法，本文将详细解释 ThreadPoolExecutor 的 submit 方法。我们需要了解 ThreadPoolExecutor 的继承关系。ThreadPoolExecutor 实现了 ExecutorService 接口，而 ExecutorService 接口继承自 Executor 接口。在 Executor 接口中，只定义了 execute 方法，而 submit 方法则是在 ExecutorService 接口中定义的。 ```java public interface ExecutorService extends Executor { ... <T> Future<T> submit(Callable<T> task); <T> Future<T> submit(Runnable task, T result); <T> Future<T> submit(Runnable task); ... } ``` 在 AbstractExecutorService 类中，实现了 submit 方法。 ```java public abstract class AbstractExecutorService implements ExecutorService { ... public <T> Future<T> submit(Callable<T> task) { if (task == null) throw new NullPointerException(); RunnableFuture<T> ftask = newTaskFor(task); execute(ftask); return ftask; } public <T> Future<T> submit(Runnable task, T result) { if (task == null) throw new NullPointerException(); RunnableFuture<T> ftask = newTaskFor(task); execute(ftask); return ftask; } public Future<?> submit(Runnable task) { if (task == null) throw new NullPointerException(); RunnableFuture<Void> ftask = newTaskFor(task, null); execute(ftask); return ftask; } ... } ``` 可以看到，submit 方法实际上是一个模板方法，定义了 submit 方法的算法骨架，其 execute 交给了子类。这也是模板方法模式的一种应用。 submit 方法可以提供线程执行的返回值，但只有实现了 Callable 才会有返回值，而实现 Runnable 的线程则是没有返回值的。也就是说，在上面的三个方法中，submit(Callable<T> task) 能获取到它的返回值，submit(Runnable task, T result) 能通过传入的载体 result 间接获得线程的返回值或者准确来说交给线程处理一下，而最后一个方法 submit(Runnable task) 则是没有返回值的，就算获取它的返回值也是 null。下面是一个使用 submit 方法的例子： ```java package com.threadpoolexecutor; import java.util.concurrent.*; public class ThreadPoolExecutorSubmitExample { public static void main(String[] args) { ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) Executors.newCachedThreadPool(); // submit(Callable<T> task) Callable<String> callable = new Callable<String>() { @Override public String call() throws Exception { return "Hello, World!"; } }; Future<String> future = threadPoolExecutor.submit(callable); try { String result = future.get(); System.out.println(result); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } // submit(Runnable task, T result) Runnable runnable = new Runnable() { @Override public void run() { System.out.println("Hello, World!"); } }; Future<String> future2 = threadPoolExecutor.submit(runnable, "Hello, World!"); try { String result = future2.get(); System.out.println(result); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } // submit(Runnable task) Runnable runnable2 = new Runnable() { @Override public void run() { System.out.println("Hello, World!"); } }; Future<?> future3 = threadPoolExecutor.submit(runnable2); try { Object result = future3.get(); System.out.println(result); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } } ``` 在这个例子中，我们创建了一个 ThreadPoolExecutor，使用 submit 方法来执行三个不同的任务。第一个任务是一个 Callable 任务，它返回一个字符串“Hello, World!”；第二个任务是一个 Runnable 任务，它打印输出“Hello, World!”，并返回一个字符串“Hello, World!”；第三个任务也是一个 Runnable 任务，它打印输出“Hello, World!”，但返回值是 null。 ThreadPoolExecutor 的 submit 方法提供了多种方式来执行任务，并且可以获取任务的返回值，这使得我们可以更灵活地使用线程池来执行任务。

如果使用`@Async`注解，Spring框架会自动将该方法包装成一个`Runnable`对象并交给`ThreadPoolTaskExecutor`的`submit`方法来执行。这个`ThreadPoolTaskExecutor`是默认情况下Spring框架提供的一个线程池，可以通过配置文件自定义线程池的参数。因此，当使用`@Async`注解时，实际上是使用`ThreadPoolTaskExecutor`来执行异步任务的。如果你使用自己创建的线程池，那么需要在配置文件中将`@EnableAsync`注解中的`executor`属性设置为你自己创建的线程池对象。

阅读全文

使用@Async时，调用的是ThreadPoolTaskExecutor的submit方法还是executor

相关推荐

spring boot中使用@Async实现异步调用任务

springboot中@Async异步调用注解的使用

java代码实现异步调用代码

Promise的链式调用和方法补充

Python中的进程池和进程池Executor

Java并发编程的黄金法则：解锁Executor框架的潜力

【函数调用分析：hotshot.stats】：深入理解函数调用栈对性能的影响

定制函数参数：Python偏函数应用与调用流程优化！

Java并发编程高级技巧：专家带你精通CompletableFuture链式调用

Python函数引用中的异步编程：实现非阻塞跨文件函数调用

【异步编程技巧】：利用ctypes.wintypes异步调用Windows API的实战指南

【gdata库与异步编程】：探索gdata库在异步环境中的使用方法

Python并发应用任务调度：策略选择与实现方法

服务状态追踪：Tornado HTTPServer监控与诊断实战方法

Python HTTPServer模块的多线程处理：提升并发性能的方法

Java线程池与Spring框架整合秘诀：流畅的集成与优化方法

threadPoolTaskExecutor用法

pool.apply_async

提供一个ThreadPoolTaskExecutor的配置并给出多线程代码案例

最新推荐

aiohttp-3.7.3-cp36-cp36m-win_amd64.whl.rar

基于Java中的swing类的图形化飞机游戏的开发练习.zip

SQLite：SQLite数据库创建与管理.docx

【完整源码+数据库】SpringBoot 集成 Spring Security短信验证码登录

去年和朋友一起做的java小游戏.游戏具体界面在readme中,游戏设计的uml图在design.pdf中.zip

探索AVL树算法：以Faculdade Senac Porto Alegre实践为例

管理建模和仿真的文件

【ggplot2绘图技巧】：R语言中的数据可视化艺术

HAL库怎样将ADC两个通道的电压结果输出到OLED上？

小学语文教学新工具：创新黑板设计解析