shell 获取命令执行结果_java高并发系列 第31天:获取线程执行结果,这6种方法你都知道?...
这是java高并发系列第31篇。
环境:jdk1.8。
java高并发系列已经学了不少东西了,本篇文章,我们用前面学的知识来实现一个需求:
在一个线程中需要获取其他线程的执行结果,能想到几种方式?各有什么优缺点?
结合这个需求,我们使用6种方式,来对之前学过的知识点做一个回顾,加深记忆。
方式1:Thread的join()方法实现
代码:
package com.itsoku.chat31;
import java.sql.Time;import java.util.concurrent.*;
/** * 跟着阿里p7学并发,微信公众号:javacode2018 */public class Demo1 { //用于封装结果 static class Result<T> { T result;
public T getResult() { return result; }
public void setResult(T result) { this.result = result; } }
public static void main(String[] args) throws ExecutionException, InterruptedException { System.out.println(System.currentTimeMillis()); //用于存放子线程执行的结果 Result result = new Result<>();//创建一个子线程 Thread thread = new Thread(() -> {try { TimeUnit.SECONDS.sleep(3); result.setResult(10); } catch (InterruptedException e) { e.printStackTrace(); } }); thread.start();//让主线程等待thread线程执行完毕之后再继续,join方法会让当前线程阻塞 thread.join();//获取thread线程的执行结果 Integer rs = result.getResult(); System.out.println(System.currentTimeMillis()); System.out.println(System.currentTimeMillis() + ":" + rs); }}
输出:
156673316263615667331656921566733165692:10
代码中通过join方式阻塞了当前主线程,当thread线程执行完毕之后,join方法才会继续执行。
此行结论有误,请跳过:join的方式,只能阻塞一个线程,如果其他线程中也需要获取thread线程的执行结果,join方法无能为力了。
关于join()方法和线程更详细的使用,可以参考:线程的基本操作
方式2:CountDownLatch实现
代码:
package com.itsoku.chat31;
import java.util.concurrent.*;
/** * 跟着阿里p7学并发,微信公众号:javacode2018 */public class Demo2 { //用于封装结果 static class Result<T> { T result;
public T getResult() { return result; }
public void setResult(T result) { this.result = result; } }
public static void main(String[] args) throws ExecutionException, InterruptedException { System.out.println(System.currentTimeMillis()); CountDownLatch countDownLatch = new CountDownLatch(1); //用于存放子线程执行的结果 Demo1.Result result = new Demo1.Result<>();//创建一个子线程 Thread thread = new Thread(() -> {try { TimeUnit.SECONDS.sleep(3); result.setResult(10); } catch (InterruptedException e) { e.printStackTrace(); }finally { countDownLatch.countDown(); } }); thread.start();//countDownLatch.await()会让当前线程阻塞,当countDownLatch中的计数器变为0的时候,await方法会返回 countDownLatch.await();//获取thread线程的执行结果 Integer rs = result.getResult(); System.out.println(System.currentTimeMillis()); System.out.println(System.currentTimeMillis() + ":" + rs); }}
输出:
156673372040615667337234531566733723453:10
上面代码也达到了预期效果,使用CountDownLatch
可以让一个或者多个线程等待一批线程完成之后,自己再继续;CountDownLatch
更详细的介绍见:JUC中等待多线程完成的工具类CountDownLatch,必备技能
方式3:ExecutorService.submit方法实现
代码:
package com.itsoku.chat31;
import java.util.concurrent.*;
/** * 跟着阿里p7学并发,微信公众号:javacode2018 */public class Demo3 { public static void main(String[] args) throws ExecutionException, InterruptedException { //创建一个线程池 ExecutorService executorService = Executors.newCachedThreadPool(); System.out.println(System.currentTimeMillis()); Future future = executorService.submit(() -> {try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); }return 10; });//关闭线程池 executorService.shutdown(); System.out.println(System.currentTimeMillis()); Integer result = future.get(); System.out.println(System.currentTimeMillis() + ":" + result); }}
输出:
156673411993815667341199891566734122989:10
使用ExecutorService.submit
方法实现的,此方法返回一个Future
,future.get()
会让当前线程阻塞,直到Future关联的任务执行完毕。
相关知识:
JAVA线程池,这一篇就够了
JUC中的Executor框架详解1
JUC中的Executor框架详解2
方式4:FutureTask方式1
代码:
package com.itsoku.chat31;
import java.util.concurrent.*;
/** * 跟着阿里p7学并发,微信公众号:javacode2018 */public class Demo4 { public static void main(String[] args) throws ExecutionException, InterruptedException { System.out.println(System.currentTimeMillis()); //创建一个FutureTask FutureTask futureTask = new FutureTask<>(() -> {try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); }return 10; });//将futureTask传递一个线程运行new Thread(futureTask).start(); System.out.println(System.currentTimeMillis());//futureTask.get()会阻塞当前线程,直到futureTask执行完毕 Integer result = futureTask.get(); System.out.println(System.currentTimeMillis() + ":" + result); }}
输出:
156673635031415667363503581566736353360:10
代码中使用FutureTask
实现的,FutureTask实现了Runnable
接口,并且内部带返回值,所以可以传递给Thread直接运行,futureTask.get()
会阻塞当前线程,直到FutureTask
构造方法传递的任务执行完毕,get方法才会返回。关于FutureTask
详细使用,请参考:JUC中的Executor框架详解1
方式5:FutureTask方式2
代码:
package com.itsoku.chat31;
import java.util.concurrent.ExecutionException;import java.util.concurrent.FutureTask;import java.util.concurrent.TimeUnit;
/** * 跟着阿里p7学并发,微信公众号:javacode2018 */public class Demo5 { public static void main(String[] args) throws ExecutionException, InterruptedException { System.out.println(System.currentTimeMillis()); //创建一个FutureTask FutureTask futureTask = new FutureTask<>(() -> 10);//将futureTask传递一个线程运行new Thread(() -> {try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); } futureTask.run(); }).start(); System.out.println(System.currentTimeMillis());//futureTask.get()会阻塞当前线程,直到futureTask执行完毕 Integer result = futureTask.get(); System.out.println(System.currentTimeMillis() + ":" + result); }}
输出:
156673631992515667363199701566736322972:10
创建了一个FutureTask
对象,调用futureTask.get()
会阻塞当前线程,子线程中休眠了3秒,然后调用futureTask.run();
当futureTask的run()方法执行完毕之后,futureTask.get()
会从阻塞中返回。
注意:这种方式和方式4的不同点。
关于FutureTask
详细使用,请参考:JUC中的Executor框架详解1
方式6:CompletableFuture方式实现
代码:
package com.itsoku.chat31;
import java.util.concurrent.CompletableFuture;import java.util.concurrent.ExecutionException;import java.util.concurrent.FutureTask;import java.util.concurrent.TimeUnit;
/** * 跟着阿里p7学并发,微信公众号:javacode2018 */public class Demo6 { public static void main(String[] args) throws ExecutionException, InterruptedException { System.out.println(System.currentTimeMillis()); CompletableFuture completableFuture = CompletableFuture.supplyAsync(() -> {try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); }return 10; }); System.out.println(System.currentTimeMillis());//futureTask.get()会阻塞当前线程,直到futureTask执行完毕 Integer result = completableFuture.get(); System.out.println(System.currentTimeMillis() + ":" + result); }}
输出:
156673620534815667362054281566736208429:10
CompletableFuture.supplyAsync
可以用来异步执行一个带返回值的任务,调用completableFuture.get()
会阻塞当前线程,直到任务执行完毕,get方法才会返回。
关于CompletableFuture
更详细的使用见:JUC中工具类CompletableFuture,必备技能
java高并发系列目录
第1天:必须知道的几个概念
第2天:并发级别
第3天:有关并行的两个重要定律
第4天:JMM相关的一些概念
第5天:深入理解进程和线程
第6天:线程的基本操作
第7天:volatile与Java内存模型
第8天:线程组
第9天:用户线程和守护线程
第10天:线程安全和synchronized关键字
第11天:线程中断的几种方式
第12天JUC:ReentrantLock重入锁
第13天:JUC中的Condition对象
第14天:JUC中的LockSupport工具类,必备技能
第15天:JUC中的Semaphore(信号量)
第16天:JUC中等待多线程完成的工具类CountDownLatch,必备技能
第17天:JUC中的循环栅栏CyclicBarrier的6种使用场景
第18天:JAVA线程池,这一篇就够了
第19天:JUC中的Executor框架详解1
第20天:JUC中的Executor框架详解2
第21天:java中的CAS,你需要知道的东西
第22天:JUC底层工具类Unsafe,高手必须要了解
第23天:JUC中原子类,一篇就够了
第24天:ThreadLocal、InheritableThreadLocal(通俗易懂)
第25天:掌握JUC中的阻塞队列
第26篇:学会使用JUC中常见的集合,常看看!
第27天:实战篇,接口性能提升几倍原来这么简单
第28天:实战篇,微服务日志的伤痛,一并帮你解决掉
第29天:高并发中常见的限流方式
第30天:JUC中工具类CompletableFuture,必备技能
阿里p7一起学并发,公众号:路人甲java,每天获取最新文章!
shell 获取命令执行结果_java高并发系列 第31天:获取线程执行结果,这6种方法你都知道?...相关推荐
- [Java高并发系列(5)][详细]Java中线程池(1)--基本概念介绍
1 Java中线程池概述 1.1 什么是线程池? 在一个应用当中, 我们往往需要多次使用线程, 这意味着我们需要多次创建和销毁线程.那么为什么不提供一个机制或概念来管理这些线程呢? 该创建的时候创建, ...
- java 检视_Java高并发系列——检视阅读(五)
JUC中工具类CompletableFuture CompletableFuture是java8中新增的一个类,算是对Future的一种增强,用起来很方便,也是会经常用到的一个工具类,熟悉一下. Co ...
- java queue源码_Java高并发系列之ArrayBlockingQueue源码解析
JUC包下定义了一个接口:BlockingQueue.其实现类有ArrayBlockingQueue等.本文先来介绍一下ArrayBlockingQueue.从字面可以看出,ArrayBlocking ...
- java中acquire()_Java高并发系列之AQS中acquire源码解析
我们知道,AQS中最重要的两个方法就是acquire和release方法.我们本文来走读走读acquire的源码. 首先,tryAcquire是需要子类具体去实现,其作用就是设置state的值,如果设 ...
- java高并发系列 - 第1天:必须知道的几个概念
java高并发系列-第1天:必须知道的几个概念 同步(Synchronous)和异步(Asynchronous) 同步和异步通常来形容一次方法调用,同步方法调用一旦开始,调用者必须等到方法调用返回后, ...
- java 秒杀 源码 下载_java高并发秒杀系统3-4节秒杀功能实现.mp4
本Java商城秒杀系统视频教程目录如下: java高并发秒杀系统1-1节java高并发商城秒杀优化学习指引.mp4 java高并发秒杀系统1-2节项目环境搭建(Eclipse)-节.mp4 ja ...
- java商品详情页设计_java高并发秒杀系统3-2节商品详情页上.mp4
本Java商城秒杀系统视频教程目录如下: java高并发秒杀系统1-1节java高并发商城秒杀优化学习指引.mp4 java高并发秒杀系统1-2节项目环境搭建(Eclipse)-节.mp4 ja ...
- java高并发系列 - 第6天:线程的基本操作,必备技能
新建线程 新建线程很简单.只需要使用new关键字创建一个线程对象,然后调用它的start()启动线程即可. Thread thread1 = new Thread1(); t1.start(); 那么 ...
- httpd开启status模块_Nginx高并发系列之二——Nginx开启ssl模块
在上一期中我们安装配置了nginx1.13.7版本并且成功启动,那么这一期就针对安装的Nginx支持ssl模块--即开启https功能.如果还有不知道如何安装与配置的请移至: 水番丘山:Nginx高并 ...
最新文章
- 400 多行代码!超详细 Rasa 中文聊天机器人开发指南 | 原力计划
- Exchange动态同步中的INTERNET_29错误代码
- slf4j日志的最优使用方式
- 80万辆车“云上飞驰”的背后
- 为什么将表格的method改为post后就无法工作_不用再等后端的接口啦!这个开源项目花 2 分钟就能模拟出后端接口...
- 收藏的一个关于C# ToString的方法集合
- “衰亡”的雅虎:30 亿用户账号全部泄漏还能怎么活?
- 计算机网络实验【利用wireshark抓包工具抓包】
- 一文读懂质量保证和质量控制
- 关于政府房价调控的一个误区
- 黑盒测试用例设计方法
- grads插值_GrADS中格点插值到站点(gr2stn)的详细方法
- 20162312大二上学期总结博客
- 解决IAR printf函数输出中文字符乱码问题
- 树莓派调用百度API实现果蔬识别部署
- Javascript removeChild()删除节点及删除子节点的方法
- 【洛谷P1606】白银莲花池【最短路】
- android第三方apk找不到/system/lib64/里面的系统库
- Java编程:随机生成数字串
- iPad pencil充放电曲线研究(娱乐向)
热门文章
- 如何处理Angular依赖注入的错误消息: NullInjectorError No provider for EffectsRootModule!
- SAP CRM 中间件Request download里,遇到/SAPPSPRO/S_MAT_ENHANC_COMM 错误的解决办法
- 使用View modification扩展SAP Fiori应用的一个案例
- Angular:where does watchers in scope come from
- 如何使用命令行拿到SAP Kyma的Lambda Function明细
- settype COM_LOCAT_ADDR出现在CRM change document里的原因
- 404 Not Found: Requested route ('jerrylist.cfapps.eu10.hana.ondemand.com') does not exist
- 点击SAP Fiori Launchpad某个tile后遇到的错误消息如何解决
- 推荐一个yaml文件转json文件的在线工具
- 如何在Java代码中使用SAP云平台CloudFoundry环境的环境变量