java异步线程_java异步线程
2022/11/5 14:53:56
本文主要是介绍java异步线程_java异步线程,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
使用一个ExecutorService,增加两个不可取消的子线程任务,并且获取他们的返回值。
@org.junit.Test
public void testFuture() throws InterruptedException {
ExecutorService executor = Executors.newCachedThreadPool();
Task task = new Task();
NewTask newTask = new NewTask();
Future result = executor.submit(task);
Future 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{
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{
public String call() throws Exception {
System.out.println("第二个子线程已经运行完毕");
return "success";
}
}
另: 如果main主线程不去获取子线程的结果,那么主线程完全可以不阻塞。那么,此时,主线程和子线程完全异步。此功能,可以做成类似MQ消息中间件之类的,消息异步进行发送。
使用一个ExecutorService,增加两个不可取消的子线程任务,并且获取他们的返回值。 @org.junit.Test public void testFuture() throws InterruptedException { ExecutorService executor = Executors.newCachedThreadPool(); Task task = new Task(); NewTask newTask = new NewTask(); Future result = executor.submit(task); Future 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{ 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{ public String call() throws Exception { System.out.println("第二个子线程已经运行完毕"); return "success"; } } 另: 如果main主线程不去获取子线程的结果,那么主线程完全可以不阻塞。那么,此时,主线程和子线程完全异步。此功能,可以做成类似MQ消息中间件之类的,消息异步进行发送。这篇关于java异步线程_java异步线程的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-15鸿蒙生态设备数量超8亿台
- 2024-05-13TiDB + ES:转转业财系统亿级数据存储优化实践
- 2024-05-09“2024鸿蒙零基础快速实战-仿抖音App开发(ArkTS版)”实战课程已上线
- 2024-05-09聊聊如何通过arthas-tunnel-server来远程管理所有需要arthas监控的应用
- 2024-05-09log4j2这么配就对了
- 2024-05-09nginx修改Content-Type
- 2024-05-09Redis多数据源,看这篇就够了
- 2024-05-09Google Chrome驱动程序 124.0.6367.62(正式版本)去哪下载?
- 2024-05-09有没有大佬知道这种数据应该怎么抓取呀?
- 2024-05-09这种运行结果里的10.100000001,怎么能最快改成10.1?