快捷導(dǎo)航

ExecutorService實(shí)現(xiàn)獲取線程返回值

更新時(shí)間：2022年08月11日 10:39:58 作者：Maggnno

這篇文章主要介紹了ExecutorService實(shí)現(xiàn)獲取線程返回值，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

什么是ExecutorService?

ExecutorService是java.util.concurrent包中的一個(gè)線程池實(shí)現(xiàn)接口。其有兩個(gè)實(shí)現(xiàn)類：ThreadPoolExecutor 和 ScheduledThreadPoolExecutor。分別用來(lái)實(shí)現(xiàn)普通線程池和延遲任務(wù)線程池。普通線程池通過(guò)配置線程池大小，能有效管理線程的調(diào)度，在執(zhí)行大量異步線程時(shí)提高程序的性能。延遲任務(wù)線程池可控制在給定多長(zhǎng)的延遲后執(zhí)行線程。想要實(shí)現(xiàn)獲取線程的返回值，可以通過(guò)ThreadPoolExecutor及其子類管理線程。

實(shí)現(xiàn)帶返回值的Callable子類

創(chuàng)建一個(gè)線程類實(shí)現(xiàn)Callable接口，重寫call方法，其中call方法相當(dāng)于Thread子類中的run方法。其內(nèi)容為線程運(yùn)行時(shí)所執(zhí)行的業(yè)務(wù)。

ThreadWithCallable.java

package thread;

import java.util.concurrent.Callable;

/**
?* ?一個(gè)包含返回值的線程類
?* @author xiezd 2018-01-14 21:40
?*
?*/
public class ThreadWithCallback implements Callable{
? ? private int number;
? ? public ThreadWithCallback(int number){
? ? ? ? this.number = number;
? ? }
? ? //相當(dāng)于Thread的run方法
? ? @Override
? ? public Object call() throws Exception {
? ? ? ? long begin = System.currentTimeMillis();
? ? ? ? int index = (int)(Math.random() * 99999999);
? ? ? ? int result = number;
? ? ? ? //隨便寫的
? ? ? ? for (int i = 1; i < index; i++) {
? ? ? ? ? ? result = (result / i ) * index;
? ? ? ? }
? ? ? ? long end = System.currentTimeMillis();
? ? ? ? return "計(jì)算數(shù)值為" + number + "的線程，花費(fèi)：" + (end - begin) + "毫秒。";
? ? }
}

創(chuàng)建線程池測(cè)試

編寫一個(gè)測(cè)試類：

1.通過(guò)Excutors工廠類獲取一個(gè)固定大小的線程池對(duì)象。
2.調(diào)用線程池對(duì)象的submit方法，參數(shù)為一個(gè)線程對(duì)象，返回值為Future對(duì)象。
3.調(diào)用Future對(duì)象的get方法獲取線程返回值。
4.關(guān)閉線程池。

App.java

package thread;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/**
?* @author xiezd 2018-01-14 21:49
?*/
public class App {
? ? public static void main(String[] args) {
? ? ? ? ExecutorService executors = Executors.newFixedThreadPool(10);
? ? ? ? try {
? ? ? ? ? ? /* 啟動(dòng)線程時(shí)會(huì)返回一個(gè)Future對(duì)象。
? ? ? ? ? ? ?* 可以通過(guò)future對(duì)象獲取現(xiàn)成的返回值。
? ? ? ? ? ? ?* 在執(zhí)行future.get()時(shí)，主線程會(huì)堵塞，直至當(dāng)前future線程返回結(jié)果。
? ? ? ? ? ? ?*/
? ? ? ? ? ? Future future1 = executors.submit(new ThreadWithCallback(20));
? ? ? ? ? ? Future future2 = executors.submit(new ThreadWithCallback(30));
? ? ? ? ? ? System.out.println(future1.get());
? ? ? ? ? ? System.out.println(future2.get());

? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? } catch (ExecutionException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }finally {
? ? ? ? ? ? executors.shutdown();
? ? ? ? }
? ? }
}

注：在future調(diào)用get方法時(shí)，主線程會(huì)阻塞(sè)，直到該線程執(zhí)行完畢返回對(duì)象了只有才繼續(xù)運(yùn)行。

如果要執(zhí)行n個(gè)線程，可以把future放入Set集合中，在所有線程都啟動(dòng)完畢后，遍歷Set取出返回值。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: