java异步线程
2015-06-08 11:54
351 查看
使用一个ExecutorService,增加两个不可取消的子线程任务,并且获取他们的返回值。
另: 如果main主线程不去获取子线程的结果,那么主线程完全可以不阻塞。那么,此时,主线程和子线程完全异步。此功能,可以做成类似MQ消息中间件之类的,消息异步进行发送。
@org.junit.Test public void testFuture() throws InterruptedException { ExecutorService executor = Executors.newCachedThreadPool(); Task task = new Task(); NewTask newTask = new NewTask(); Future<Integer> result = executor.submit(task); Future<String> ends = executor.submit(newTask); executor.shutdown(); System.out.println("主线程开始运行"); System.out.println("主线程做一些复杂任务"); Thread.sleep(10000); System.out.println("主线程需要子线程的计算结果"); try { System.out.println("主线程得到子线程的结果:"+result.get()); System.out.println("主线程需要第二个子线程的数据:"+ends.get()); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } System.out.println("所有均完毕"); } } class Task implements Callable<Integer>{ public Integer call() throws Exception { System.out.println("子线程计算开始"); Thread.sleep(3000); int sum = 0; for (int i=0;i<100000;i++){ sum += i ; } System.out.println("子线程已经计算完毕"); return sum; } } class NewTask implements Callable<String>{ public String call() throws Exception { System.out.println("第二个子线程已经运行完毕"); return "success"; } }
另: 如果main主线程不去获取子线程的结果,那么主线程完全可以不阻塞。那么,此时,主线程和子线程完全异步。此功能,可以做成类似MQ消息中间件之类的,消息异步进行发送。
相关文章推荐
- eclipse 和 adt 适应mac的Retina字体设置
- struts2的配置
- Eclipse spring基本配置步骤
- java.lang.IllegalStateException: commit already called 的处理办法
- 一条命令安装服务器java
- Java批量生成Mac地址到文件
- Java中异常处理相关笔记
- 【DataStructure】The description of Java Collections Framework
- Java8中新增的Stream API
- Struts2项目配置
- Eclipse工具使用技巧总结
- Spring -- 三种配置方式
- Spring -- 三种配置方式
- Spring -- 三种配置方式
- Java开发中的23种设计模式详解
- java编程:java反射机制原理案例详解
- Java 远程调试
- 软件包javax.servlet不存在的解决办法
- POI导出大量数据的简单解决方案(附源码)-Java-POI导出大量数据,导出Excel文件,压缩ZIP(转载自iteye.com)
- Yosemite下安装jdk、mysql、maven、idea