异步]8 种 Java 异步实现
最编程
2024-07-16 16:12:11
...
异步执行对于开发者来说并不陌生,在实际的开发过程中,很多场景多会使用到异步,相比同步执行,异步可以大大缩短请求链路耗时时间,比如:发送短信、邮件。
异步的八种实现方式:
- 线程异步
Thread/Runnable
-
Future
+Callable
- 异步框架
CompletableFuture
- Spring 注解
@Async
-
Spring ApplicationEvent
事件 - 第三方异步框架,比如 Hutool 的
ThreadUtil
-
Guava
异步 - 消息队列
1、线程异步
public class ThreadTest implements Runnable{
@Override
public void run() {
System.out.println(Thread.currentThread().getName());
}
public static void main(String[] args) {
ThreadTest threadTest = new ThreadTest();
new Thread(threadTest).start();
}
}
当然,如果每次都创建一个 Thread 线程,频繁的创建、销毁,浪费系统资源,我们可以采用线程池:【Thread】线程池的 7 种创建方式及自定义线程池
2、Future 异步
public class FutureTest {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(1);
Future<String> future = executor.submit(() -> {
Thread.sleep(2000);
return "this is future execute final result!!!";
});
//这里需要返回值时会阻塞主线程
String result = future.get();
System.out.println(result);
executor.shutdown();
}
}
Future的不足之处的包括以下几点:
- 无法被动接收异步任务的计算结果:虽然我们可以主动将异步任务提交给线程池中的线程来执行,但是待异步任务执行结束之后,主线程无法得到任务完成与否的通知,它需要通过get方法主动获取任务执行的结果。
- Future件彼此孤立:有时某一个耗时很长的异步任务执行结束之后,你想利用它返回的结果再做进一步的运算,该运算也会是一个异步任务,两者之间的关系需要程序开发人员手动进行绑定赋予,Future并不能将其形成一个任务流(pipeline),每一个Future都是彼此之间都是孤立的,所以才有了后面的CompletableFuture,CompletableFuture就可以将多个Future串联起来形成任务流。
- Futrue没有很好的错误处理机制:截止目前,如果某个异步任务在执行发的过程中发生了异常,调用者无法被动感知,必须通过捕获get方法的异常才知晓异步任务执行是否出现了错误,从而在做进一步的判断处理
3、CompletableFuture
关于 CompletableFuture
更多详情请看:【异步】Futurn、FutureTask、CompletionService、CompletableFuture
public static void thenRunAsync() throws ExecutionException, InterruptedException {
CompletableFuture<Integer> cf1 = CompletableFuture.supplyAsync(() -> {
System.out.println(Thread.currentThread() + " cf1 do something....");
return 1;
});
CompletableFuture<Void> cf2 = cf1.thenRunAsync(() -> {
System.out.println(Thread.currentThread() + " cf2 do something...");
});
//等待任务1执行完成
System.out.println("cf1结果->" + cf1.get());
//等待任务2执行完成
System.out.println("cf2结果->" + cf2.get());
}
4、Spring 注解 @Async
@Configuration
public class ThreadPoolConfig {
@Bean("taskExecutor")
public Executor taskExecutor() {
//返回可用处理器的Java虚拟机的数量 12
int i = Runtime.getRuntime().availableProcessors();
System.out.println("系统最大线程数 : " + i);
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//核心线程池大小
executor.setCorePoolSize(16);
//最大线程数
executor.setMaxPoolSize(20);
//配置队列容量,默认值为Integer.MAX_VALUE
executor.setQueueCapacity(99999);
//活跃时间
executor.setKeepAliveSeconds(60);
//线程名字前缀
executor.setThreadNamePrefix("asyncServiceExecutor -");
//设置此执行程序应该在关闭时阻止的最大秒数,以便在容器的其余部分继续关闭之前等待剩余的任务完成他们的执行
executor.setAwaitTerminationSeconds(60);
//等待所有的任务结束后再关闭线程池
executor.setWaitForTasksToCompleteOnShutdown(true);
return executor;
}
}
@Service
@EnableAsync
public class AsyncServiceImpl implements AsyncService {
@Override
@Async("taskExecutor")
public String sendSms() {
System.out.println(Thread.currentThread().getName());
return null;
}
@Override
@Async("taskExecutor")
public String sendEmail() {
System.out.println(Thread.currentThread().getName());
return null;
}
}
在实际项目中, 使用 @Async
调用线程池,推荐等方式是是使用自定义线程池的模式,不推荐直接使用 @Async
直接实现异步
5、Spring ApplicationEvent
事件
Spring 中使用事件只需要以下的几个步骤:
- 定义事件,继承
ApplicationEvent
- 定义监听,要么实现
ApplicationListener
接口,要么在方法上添加@EventListener
注解 - 定义发布事件接口,调用
ApplicationContext.publishEvent()
或者ApplicationEventPublisher.publishEvent();
- 业务调用发布事件
@Getter
@Setter
public class BaseEvent<T> extends ApplicationEvent {
private T data;
public BaseEvent(Object source) {
super(source);
}
public BaseEvent(Object source, T data) {
super(source);
this.data = data;
}
}
@Component
public class BaseEventListener implements ApplicationListener<BaseEvent<UserVo>> {
@Override
@Async("taskExecutor")
public void onApplicationEvent(BaseEvent<UserVo> baseEvent) {
UserVo eventData = baseEvent.getData();
// TODO 业务处理
}
}
@Autowired
private ApplicationContext applicationContext;
@GetMapping("/pubEvent")
public void pubEvent() {
BaseEvent<UserVo> baseEvent = new BaseEvent<>("event", new UserVo());
applicationContext.publishEvent(baseEvent);
}
6、Hutool 的 ThreadUtil
public static void main(String[] args) {
for (int i = 0; i < 3; i++) {
ThreadUtil.execAsync(() -> {
ThreadLocalRandom threadLocalRandom = ThreadLocalRandom.current();
int number = threadLocalRandom.nextInt(20) + 1;
System.out.println(number);
});
log.info("当前第:" + i + "个线程");
}
log.info("task finish!");
}
7、 Guava
异步
public static void test() {
ListeningExecutorService executorService = MoreExecutors.listeningDecorator(Executors.newCachedThreadPool());
final ListenableFuture<Integer> listenableFuture = executorService.submit(() -> {
log.info("callable execute...");
TimeUnit.SECONDS.sleep(1);
return 1;
});
Futures.addCallback(listenableFuture, new FutureCallback<Integer>() {
@Override
public void onSuccess(@Nullable Integer integer) {
System.out.println("Get listenable future's result with callback " + integer);
}
@Override
public void onFailure(Throwable throwable) {
throwable.printStackTrace();
}
}, Executors.newCachedThreadPool());
}
8、 消息队列
常用的消息队列:RabbitMq
、RocketMq
上一篇: Java 异步编程最佳实践
下一篇: 异步调用的 Java 实现
推荐阅读
-
Java 8新特性探究(十三)JavaFX 8新特性以及开发2048游戏-JavaFX历史## 跟java在服务器端和web端成绩相比,桌面一直是java的软肋,于是Sun公司在2008年推出JavaFX,弥补桌面软件的缺陷,请看下图JavaFX一路走过来的改进 从上图看出,一开始推出时候,开发者需使用一种名为JavaFX Script的静态的、声明式的编程语言来开发JavaFX应用程序。因为JavaFX Script将会被编译为Java bytecode,程序员可以使用Java代码代替。 JavaFX 2.0之后的版本摒弃了JavaFX Script语言,而作为一个Java API来使用。因此使用JavaFX平台实现的应用程序将直接通过标准Java代码来实现。 JavaFX 2.0 包含非常丰富的 UI 控件、图形和多媒体特性用于简化可视化应用的开发,WebView可直接在应用中嵌入网页;另外 2.0 版本允许使用 FXML 进行 UI 定义,这是一个脚本化基于 XML 的标识语言。 从JDK 7u6开始,JavaFx就与JDK捆绑在一起了,JavaFX团队称,下一个版本将是8.0,目前所有的工作都已经围绕8.0库进行。这是因为JavaFX将捆绑在Java 8中,因此该团队决定跳过几个版本号,迎头赶上Java 8。 ##JavaFx8的新特性 ## ###全新现代主题:Modena 新的Modena主题来替换原来的Caspian主题。不过在Application的start方法中,可以通过setUserAgentStylesheet(STYLESHEET_CASPIAN)来继续使用Caspian主题。 参考http://fxexperience.com/2013/03/modena-theme-update/ ###JavaFX 3D 在JavaFX8中提供了3D图像处理API,包括Shape3D (Box, Cylinder, MeshView, Sphere子类),SubScene, Material, PickResult, LightBase (AmbientLight 和PointLight子类),SceneAntialiasing等。Camera类也得到了更新。从JavaDoc中可以找到更多信息。 ###富文本 强化了富文本的支持 ###TreeTableView ###日期控件DatePicker 增加日期控件 ###用于 CSS 结构的公共 API
-
【重写后】使用Deferred方式实现异步调用,提升系统吞吐量的Spring Boot技巧
-
C# WinForm中TCP/IP异步通信实现及心跳检测
-
8种Vue实现页面跳转并传递参数的方法解析
-
使用 MSMQ 实现日志记录的异步处理方法
-
实战!Java单元测试中如何测试异步接口?
-
四种布隆过滤器的实现方法(Java、Guava、hutool和Redisson)- 布隆过滤器简介
-
如何实现74161的同步和异步级联?—— 数字电子技术探讨
-
用 Java 8 实现函数式编程和 Lambda 表达式操作 Stream 流
-
设计异步FIFO(先进先出队列)的实现方法