淺談在Java中使用Callable、Future進行并行編程
更新時間：2017年12月06日 08:43:04 作者：老鷹
這篇文章主要介紹了淺談在Java中使用Callable、Future進行并行編程，具有一定借鑒價值，需要的朋友可以參考下。
使用Callable、Future進行并行編程
在Java中進行并行編程最常用的方式是繼承Thread類或者實現(xiàn)Runnable接口。這兩種方式的缺點是在任務(wù)完成后無法直接獲取執(zhí)行結(jié)果，必須通過共享變量或線程間通信，使用起來很不方便。
從Java1.5開始提供了Callable和Future兩個接口，通過使用它們可以在任務(wù)執(zhí)行完畢后得到執(zhí)行結(jié)果。
下面我們來學(xué)習(xí)下如何使用Callable、Future和FutureTask。
Callable接口
Callable接口位于java.util.concurrent包，這是一個泛型接口，里面只聲明了一個call()方法：
public interface Callable<T> {
T call() throws Exception;
}
一般配合ExecutorService接口來使用它，在ExecutorService接口中聲明了幾個重載的submit方法：
<T> Future<T> submit(Callable<T> task); <T> Future<T> submit(Runnable task, T result); Future<?> submit(Runnable task);
第一個submit方法里面的參數(shù)類型就是Callable，另外兩個本文暫時不涉及。
Future和FutureTask
Future接口的實現(xiàn)類可以對Runnable或者Callable的任務(wù)執(zhí)行取消、查詢、獲取結(jié)果的操作。
Future接口也位于java.util.concurrent包下：
public interface Future<T> {
/**
*取消任務(wù)
*@param mayInterruptIfRunning
*是否允許取消正在執(zhí)行卻沒有執(zhí)行完畢的任務(wù)，如果設(shè)置true，則表示可以取消正在執(zhí)行過程中的任務(wù)
*如果任務(wù)正在執(zhí)行，則返回true
*如果任務(wù)還沒有執(zhí)行，則無論mayInterruptIfRunning為true還是false，返回true
*如果任務(wù)已經(jīng)完成，則無論mayInterruptIfRunning為true還是false，返回false
*/
boolean cancel(boolean mayInterruptIfRunning);
/**
*任務(wù)是否被取消成功，如果在任務(wù)正常完成前被取消成功，則返回 true
*/
boolean isCancelled();
/**
*任務(wù)是否完成
*/
boolean isDone();
/**
*通過阻塞獲取執(zhí)行結(jié)果
*/
T get() throws InterruptedException, ExecutionException;
/**
*通過阻塞獲取執(zhí)行結(jié)果。如果在指定的時間內(nèi)沒有返回，則返回null
*/
T get(long timeout, TimeUnit unit)
throws InterruptedException, ExecutionException, TimeoutException;
}
總結(jié)下來Future提供了三種功能：
判斷任務(wù)是否完成 能夠中斷任務(wù) 能夠獲取任務(wù)執(zhí)行的結(jié)果
JDK中為我們提供了一個Future接口的實現(xiàn)類FutureTask，它有如下兩個構(gòu)造函數(shù)。
public FutureTask(Callable<T> callable) {
}
public FutureTask(Runnable runnable, T result) {
}
示例代碼
使用Callable、Future
import java.util.concurrent.*;
public class Test {
public static void main(String[] args) {
ExecutorService executorService = Executors.newCachedThreadPool();
Task task = new Task();
Future<Integer> future = executorService.submit(task);
executorService.shutdown();
System.out.println("主線程在執(zhí)行任務(wù)...");
try {
Thread.sleep(2000);
} catch(InterruptedException ex) {
ex.printStackTrace();
}
try {
System.out.println("task運行結(jié)果:"+future.get());
} catch (InterruptedException ex) {
ex.printStackTrace();
} catch (ExecutionException ex) {
ex.printStackTrace();
}
System.out.println("所有任務(wù)執(zhí)行完畢");
}
}
class Task implements Callable<Integer>{
@Override
public Integer call() throws Exception {
System.out.println("子線程在執(zhí)行任務(wù)...");
//模擬任務(wù)耗時
Thread.sleep(5000);
return 1000;
}
}
執(zhí)行結(jié)果：
子線程在執(zhí)行任務(wù)... 主線程在執(zhí)行任務(wù)... task運行結(jié)果:1000 所有任務(wù)執(zhí)行完畢
使用Callable、FutureTask
import java.util.concurrent.*;
public class Test {
public static void main(String[] args) {
ExecutorService executorService = Executors.newCachedThreadPool();
Task task = new Task();
FutureTask<Integer> futureTask = new FutureTask<Integer>(task);
executorService.submit(futureTask);
executorService.shutdown();
System.out.println("主線程在執(zhí)行任務(wù)...");
try {
Thread.sleep(2000);
} catch (InterruptedException ex) {
ex.printStackTrace();
}
try {
System.out.println("task運行結(jié)果:"+futureTask.get());
} catch (InterruptedException ex) {
ex.printStackTrace();
} catch (ExecutionException ex) {
ex.printStackTrace();
}
System.out.println("所有任務(wù)執(zhí)行完畢");
}
}
class Task implements Callable<Integer>{
@Override
public Integer call() throws Exception {
System.out.println("子線程在執(zhí)行任務(wù)...");
//模擬任務(wù)耗時
Thread.sleep(5000);
return 1000;
}
}
執(zhí)行結(jié)果：
子線程在執(zhí)行任務(wù)... 主線程在執(zhí)行任務(wù)... task運行結(jié)果:1000 所有任務(wù)執(zhí)行完畢
總結(jié)
以上就是本文關(guān)于淺談在Java中使用Callable、Future進行并行編程的全部內(nèi)容，希望對大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站其他相關(guān)專題，如有不足之處，歡迎留言指出。感謝朋友們對本站的支持！
相關(guān)文章
Mybatis-Plus?是?MyBatis?的一個增強工具，專門針對于傳統(tǒng)MyBatis開發(fā)中sql需要手動進行映射配置繁瑣缺點的一款框架技術(shù)。本文將為大家詳細講講Mybatis-plus的介紹與使用，感興趣的可以了解一下2022-07-07
這篇文章主要介紹了關(guān)于Java虛擬機HotSpot，在Java類中的一些方法會被由C/C++編寫的HotSpot虛擬機的C/C++函數(shù)調(diào)用，不過由于Java方法與C/C++函數(shù)的調(diào)用約定不同，所以并不能直接調(diào)用，需要JavaCalls::call()這個函數(shù)輔助調(diào)用，下面我們來看看文章對內(nèi)容的具體介紹2021-11-11
Java使用Lua實現(xiàn)動態(tài)擴展和腳本自動升級
Lua是一種輕量級的腳本語言,常用于游戲開發(fā)和嵌入式系統(tǒng)中,這篇文章主要介紹了Java如何調(diào)用Lua實現(xiàn)動態(tài)擴展和腳本自動升級,感興趣的可以學(xué)習(xí)下2023-08-08
本文主要介紹了SpringBoot中注冊過濾器的幾種實現(xiàn)方式,主要介紹了三種方式,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-01-01
這篇文章主要介紹了淺談java如何生成分享海報工具類，想了解分享海報知識的同學(xué)不要錯過哦2021-04-04
下面小編就為大家?guī)硪黄狫AVA基礎(chǔ)之控制臺輸入輸出的實例代碼。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2016-07-07
Spring核心容器之ApplicationContext上下文啟動準(zhǔn)備詳解
這篇文章主要介紹了Spring核心容器之ApplicationContext上下文啟動準(zhǔn)備詳解,ApplicationContext 繼承自 BeanFactory ,其不僅包含 BeanFactory 所有功能,還擴展了容器功能,需要的朋友可以參考下2023-11-11
java利用htmlparser獲取html中想要的代碼具體實現(xiàn)
這篇文章主要介紹了java利用htmlparser獲取html中想要的代碼具體實現(xiàn),需要的朋友可以參考下2014-02-02
這篇文章主要介紹了完美解決PermGen space異常的問題，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-01-01
這篇文章主要給大家介紹了關(guān)于使用idea開發(fā)Servlet的相關(guān)資料,將idea添加servlet的過程其實非常簡單,只需要按照以下幾個步驟即可完成,需要的朋友可以參考下2023-10-10