网站首页 > 精选教程 正文
场景描述,性能能优化一种比较常见的处理方式是把串行任务,开始->A->B->C->结束,改成并行,如果A、B、C分别耗时1s,该异步之后最终耗时基本是1s
先列出几种常见的写法
1 原始写法wait/notify方式,下面代码执行结果是
主线程执行等待
子线程执行完成
主线程执行完成
//创建一个线程处理子任务,任务执行1s
Thread thread = new Thread(() -> {
try {
//do something
System.out.println("子线程执行完成");
} finally {
synchronized (this) {
notifyAll();
}
}
});
thread.start();
System.out.println("主线程执行等待");
//阻塞线程
synchronized (this) {
try {
wait();
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
System.out.println("主线程执行完成");
2 第二用CountDownLatch实现对主线程阻塞,稍微简单一点点
//参数1 表示对一个子任务
CountDownLatch c = new CountDownLatch(1);
//创建一个线程,任务执行1s
Thread thread = new Thread(() -> {
try {
//do something
System.out.println("子线程执行完成");
} finally {
c.countDown();
}
});
thread.start();
System.out.println("主线程执行等待");
//阻塞线程
try {
c.await();
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
System.out.println("主线程执行完成");
3 用future方式,现在来看又简单一点了
ExecutorService executorService = Executors.newSingleThreadExecutor();
Future<?> future = executorService.submit(() -> {
System.out.println("子线程执行完成");
});
System.out.println("主线程执行等待");
//阻塞线程
try {
future.get();
} catch (Exception e) {
throw new RuntimeException(e);
}
System.out.println("主线程执行完成");
4 上面代码还不是最优解,jdk还有一种服务编排,让大家感受下,是不是简单很多
ExecutorService executorService = Executors.newSingleThreadExecutor();
System.out.println("主线程执行等待");
CompletableFuture.allOf(CompletableFuture.runAsync(()->{
System.out.println("子线程执行完成");
}, executorService)).join();
System.out.println("主线程执行完成");
5 如果我一次性要并行执行多个子任务,上面代码还不是最优解,下面是自己封装的一个工具类,后续发到代码仓库中,写法如下
System.out.println("主线程执行等待");
AsyncUtil.instance().add(()->{
System.out.println("子线程执行完成");
}).join();
System.out.println("主线程执行完成");
这样是不是比上面代码简单很多,多个并行任务的写法如下
AsyncUtil.instance().add(()->{
System.out.println("子线程1执行完成");
}).add(()->{
System.out.println("子线程2执行完成");
}).join();
创作不易,希望得到的关注和点赞~
- 上一篇: java编程异步通信
- 下一篇: Spring Boot 优雅的实现CORS跨域,java异步请求原理
猜你喜欢
- 2024-11-27 多线程技术(同步异步,并发并行)守护线程(java垃圾回收机制)
- 2024-11-27 Java 爬虫遇上数据异步加载,试试这两种办法
- 2024-11-27 Java 17 多线程的同步和异步synchronized关键字
- 2024-11-27 java异步编程产生的原因
- 2024-11-27 Java:了解Java中的异步套接字通道
- 2024-11-27 Java面试常见问题:阻塞与非阻塞,同步与异步
- 2024-11-27 parseq-让java异步并发编程更简单
- 2024-11-27 Java异步记录日志-2022新项目
- 2024-11-27 Java异步编程实战:基于JDK中的Future实现异步编程
- 2024-11-27 Java8异步编程就是拽的不行
你 发表评论:
欢迎- 04-11Java面试“字符串三兄弟”String、StringBuilder、StringBuffer
- 04-11Java中你知道几种从字符串中找指定的字符的数量
- 04-11探秘Java面试中问的最多的String、StringBuffer、StringBuilder
- 04-11Python字符串详解与示例(python字符串的常见操作)
- 04-11java正则-取出指定字符串之间的内容
- 04-11String s1 = new String("abc");这句话创建了几个字符串对象?
- 04-11java判断字符串中是否包含某个字符
- 04-11关于java开发中正确的发牌逻辑编写规范
- 最近发表
-
- Java面试“字符串三兄弟”String、StringBuilder、StringBuffer
- Java中你知道几种从字符串中找指定的字符的数量
- 探秘Java面试中问的最多的String、StringBuffer、StringBuilder
- Python字符串详解与示例(python字符串的常见操作)
- java正则-取出指定字符串之间的内容
- String s1 = new String("abc");这句话创建了几个字符串对象?
- java判断字符串中是否包含某个字符
- 关于java开发中正确的发牌逻辑编写规范
- windows、linux如何后台运行jar(并且显示进程名)
- 腾讯大佬私人收藏,GitHub上最受欢迎的100个JAVA库,值得学习
- 标签列表
-
- nginx反向代理 (57)
- nginx日志 (56)
- nginx限制ip访问 (62)
- mac安装nginx (55)
- java和mysql (59)
- java中final (62)
- win10安装java (72)
- java启动参数 (64)
- java链表反转 (64)
- 字符串反转java (72)
- java逻辑运算符 (59)
- java 请求url (65)
- java信号量 (57)
- java定义枚举 (59)
- java字符串压缩 (56)
- java中的反射 (59)
- java 三维数组 (55)
- java插入排序 (68)
- java线程的状态 (62)
- java异步调用 (55)
- java中的异常处理 (62)
- java锁机制 (54)
- java静态内部类 (55)
- java怎么添加图片 (60)
- java 权限框架 (55)
本文暂时没有评论,来添加一个吧(●'◡'●)