詳解JDK中ExecutorService與Callable和Future對線程的支持
詳解JDK中ExecutorService與Callable和Future對線程的支持
1、代碼背景：
假如有Thread1、Thread2、Thread3、Thread4四條線程分別統(tǒng)計C、D、E、F四個盤的大小，所有線程都統(tǒng)計完畢交給Thread5線程去做匯總，應(yīng)當(dāng)如何實(shí)現(xiàn)？
2、代碼：
統(tǒng)計“盤子”大小的代碼，此處實(shí)現(xiàn)jdk中的Callable接口，
package com.wang.test.concurrent;
import java.util.concurrent.Callable;
public class Task1 implements Callable<Integer> {
private int x;
private int y;
public Task1(int x, int y) {
this.x = x;
this.y = y;
}
@Override
public Integer call() throws Exception {
return x*y;
}
}
統(tǒng)計匯總的代碼，也是實(shí)現(xiàn)jdk中的Callable接口，
package com.wang.test.concurrent;
import java.util.concurrent.Callable;
public class Task2 implements Callable<Integer> {
private int x;
private int y;
private int q;
private int w;
public Task2(int x, int y, int q, int w) {
this.x = x;
this.y = y;
this.q = q;
this.w = w;
}
@Override
public Integer call() throws Exception {
return x + y + q + w;
}
}
客戶端：使用JDK中Executors.newFixedThreadPool方法創(chuàng)建ExecutorService，ExecutorService的submit方法接收Callable接口的實(shí)現(xiàn)，JDK內(nèi)部將弄成線程處理，使用Future接收submit方法的返回值，當(dāng)future調(diào)用get方法時，如果線程還沒有執(zhí)行完，程序阻塞在這里，知道線程執(zhí)行完。
package com.wang.test.concurrent;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class Client {
public static void main(String[] args) throws Exception {
ExecutorService pool = Executors.newFixedThreadPool(4);
Task1 t1 = new Task1(1,2);
Task1 t2 = new Task1(23,34);
Task1 t3 = new Task1(23,456);
Task1 t4 = new Task1(3,33);
Future<Integer> f1 = pool.submit(t1);
Future<Integer> f2 = pool.submit(t2);
Future<Integer> f3 = pool.submit(t3);
Future<Integer> f4 = pool.submit(t4);
//Future調(diào)用get方法時，如果線程還沒有執(zhí)行完，程序阻塞在這里
Task2 t5 = new Task2(f1.get(), f2.get(), f3.get(), f4.get());
Future<Integer> f5 = pool.submit(t5);
System.out.println(f5.get());
pool.shutdown();
}
}
如有疑問請留言或者到本站社區(qū)交流討論，感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了識別率很高的java文字識別技術(shù)，親測，希望對大家有幫助，感興趣的小伙伴們可以參考一下2016-08-08
這篇文章主要介紹了Spring事務(wù)的七種傳播行為，文章圍繞主題的相關(guān)資料展開詳細(xì)的內(nèi)容解說，具有一定的參考價值，需要的小伙伴可以參考一下2022-04-04
面向?qū)ο竽耸荍ava語言的核心，是程序設(shè)計的思想，在面向?qū)ο蟪淌皆O(shè)計方法中，封裝（英語：Encapsulation）是指一種將抽象性函式接口的實(shí)現(xiàn)細(xì)節(jié)部分包裝、隱藏起來的方法。封裝可以被認(rèn)為是一個保護(hù)屏障，防止該類的代碼和數(shù)據(jù)被外部類定義的代碼隨機(jī)訪問2021-10-10
IDEA將Maven項(xiàng)目中指定文件夾下的xml等文件編譯進(jìn)classes的方法
這篇文章主要介紹了IDEA將Maven項(xiàng)目中指定文件夾下的xml等文件編譯進(jìn)classes的方法，幫助大家更好的利用IDEA進(jìn)行Java的開發(fā)學(xué)習(xí)，感興趣的朋友可以了解下2021-01-01
Java內(nèi)存區(qū)域與內(nèi)存溢出異常詳解
這篇文章主要介紹了Java內(nèi)存區(qū)域與內(nèi)存溢出異常詳解的相關(guān)資料,需要的朋友可以參考下2017-03-03
詳解使用SSM實(shí)現(xiàn)簡單工作流系統(tǒng)之實(shí)現(xiàn)篇
這篇文章主要介紹了使用SSM實(shí)現(xiàn)簡單工作流系統(tǒng)之實(shí)現(xiàn)篇，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-12-12
這篇文章主要介紹了Java線程狀態(tài)運(yùn)行原理解析,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2019-12-12
Mybatis逆向工程實(shí)現(xiàn)連接MySQL數(shù)據(jù)庫
本文主要介紹了Mybatis逆向工程實(shí)現(xiàn)連接MySQL數(shù)據(jù)庫，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-06-06
java 查找list中重復(fù)數(shù)據(jù)實(shí)例詳解
這篇文章主要介紹了java 查找list中重復(fù)數(shù)據(jù)實(shí)例詳解的相關(guān)資料,需要的朋友可以參考下2017-01-01
這篇文章主要介紹了Nacos配置中心搭建及動態(tài)刷新配置及踩坑記錄，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-11-11