Java中的Callable實(shí)現(xiàn)多線程詳解
Java中的Callable實(shí)現(xiàn)多線程
從Java提供多線程開始,最初的方案就是依靠Runnable接口定義線程類核心功能,但是Runnable中的run方法有一個(gè)缺點(diǎn):該方法沒有返回值。
從JDK1.5開始,在JUC(java.util.concurrent)包中提供了一個(gè)新的多線程實(shí)現(xiàn)接口:
@FunctionalInterface public interface Callable<V>{ public V call() throws Exception; }
接口Callable中有一個(gè)call方法,其返回值類型為V,這是一個(gè)泛型。
值得關(guān)注的是這個(gè)call方法有返回值,這意味著線程執(zhí)行完畢后可以將處理結(jié)果返回。
根據(jù)以往的套路,我們要?jiǎng)?chuàng)建一個(gè)實(shí)現(xiàn)Callable的的類,將其作為線程主體,這個(gè)類要覆寫call方法(其實(shí)call方法和run方法類似):
class MyThread4 implements Callable<String>{ // 定義核心業(yè)務(wù)類 private String name; public MyThread4(String name) { this.name = name; } @Override public String call() throws Exception { for(int i = 0 ; i < 100; i++) { System.out.println(this.name + "線程運(yùn)行, x = " + i); } return "執(zhí)行完畢"; // 返回值 } }
定義好了相應(yīng)的線程執(zhí)行類,就要用Thread的start()方法啟動(dòng)線程,但是表面上看Callable和Thread并沒有聯(lián)系,這需要我們深入的挖掘源碼:
1、我們先從Java API中的java.util.concurrent包內(nèi)找到Future<V>
public interface Future<V>{ V get() throws InterruptedException, ExecutionException; }
可以發(fā)現(xiàn)接口Future中有一個(gè)get()方法,注意:這個(gè)get()方法可以獲取callable方法的返回值。
那現(xiàn)在我們可以獲取Callable的返回值,但是,依舊看不出和Thread的關(guān)系。
2、再回到j(luò)ava.util.concurrent包中,找到RunnableFuture<V>
public interface RunnableFuture<V> extends Runnable, Future<V>{ void run(); }
這里我們先不關(guān)注run()方法,注意接口RunnableFuture繼承了接口Runnable和接口Future<V>。
3、查看Runnable的實(shí)現(xiàn)類,發(fā)現(xiàn)了FutureTask<V>,F(xiàn)utureTask<V>有兩個(gè)構(gòu)造方法,我們關(guān)注其中一個(gè):
public FutureTask(Callable<V> callable)
這個(gè)構(gòu)造方法可傳callable的實(shí)現(xiàn)類,而FutureTask又繼承了Runnable。
所以Callable傳給FutureTask,F(xiàn)utureTask又繼承了Runnable,F(xiàn)utureTask就能作為Runnable傳給Thread,start()方法就得以調(diào)用。
Callable與Runnable兩個(gè)多線程接口最大的差別在于Callable有返回值。
實(shí)際使用哪個(gè)要看具體的需求。
完整代碼:
class MyThread4 implements Callable<String>{ // 定義核心業(yè)務(wù)類 private String name; public MyThread4(String name) { this.name = name; } @Override public String call() throws Exception { for(int i = 0 ; i < 100; i++) { System.out.println(this.name + "線程運(yùn)行, x = " + i); } return "執(zhí)行完畢"; // 返回值 } } public class CallableTest { public static void main(String[] args) throws Exception{ Callable<String> callA = new MyThread4("線程A"); Callable<String> callB = new MyThread4("線程B"); Callable<String> callC = new MyThread4("線程C"); FutureTask<String> futureA = new FutureTask<String>(callA); FutureTask<String> futureB = new FutureTask<String>(callB); FutureTask<String> futureC = new FutureTask<String>(callC); new Thread(futureA).start(); new Thread(futureB).start(); new Thread(futureC).start(); System.out.println("A執(zhí)行返回結(jié)果:" + futureA.get()); System.out.println("B執(zhí)行返回結(jié)果:" + futureB.get()); System.out.println("C執(zhí)行返回結(jié)果:" + futureC.get()); } }
到此這篇關(guān)于Java中的Callable實(shí)現(xiàn)多線程詳解的文章就介紹到這了,更多相關(guān)Java的Callable多線程內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- Java使用多線程批次查詢大量數(shù)據(jù)(Callable返回?cái)?shù)據(jù))方式
- Java通過Callable實(shí)現(xiàn)多線程
- Java多線程中Callable和Future的解讀
- Java使用Callable接口實(shí)現(xiàn)多線程的實(shí)例代碼
- Java多線程實(shí)現(xiàn)之Callable詳解
- Java中Runnable和Callable分別什么時(shí)候使用
- Java中Runnable與Callable接口的區(qū)別詳解
- 詳解Java中Callable和Future的區(qū)別
- Java使用Runnable和Callable實(shí)現(xiàn)多線程的區(qū)別詳解
- java面試常問的Runnable和Callable的區(qū)別
- Java并發(fā)教程之Callable和Future接口詳解
- Java中callable的實(shí)現(xiàn)原理
相關(guān)文章
Java中負(fù)數(shù)的絕對值竟然不一定是正數(shù)
這篇文章主要介紹了Java中負(fù)數(shù)的絕對值竟然不一定是正數(shù),文中給大家提到Java 中怎么把負(fù)數(shù)轉(zhuǎn)換為正數(shù),需要的朋友可以參考下2021-07-07基于springboot的flowable工作流實(shí)戰(zhàn)流程分析
這篇文章主要介紹了基于springboot的flowable工作流實(shí)戰(zhàn)流程分析,本文給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-10-10導(dǎo)入renren-fast出現(xiàn)問題以及解決方案
文章介紹了在導(dǎo)入renren-fast項(xiàng)目時(shí)遇到的maven繼承parent問題,并提供了解決方案,即在pom文件中添加``標(biāo)簽,此外,還詳細(xì)解釋了Maven的``標(biāo)簽的作用以及MAVEN構(gòu)建jar包時(shí)的查找順序2024-11-11Spring Boot2.0中SpringWebContext找不到無法使用的解決方法
這篇文章主要給大家介紹了關(guān)于Spring Boot2.0中SpringWebContext找不到無法使用的解決方法,文中通過示例代碼介紹的非常詳細(xì),需要的朋友可以參考借鑒,下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2018-12-12Java實(shí)現(xiàn)月餅的制作、下單和售賣功能
這篇文章主要介紹了Java實(shí)現(xiàn)月餅的制作、下單和售賣,借此機(jī)會(huì),我們用Lambda實(shí)現(xiàn)一遍月餅制作,下單,售賣的開發(fā)設(shè)計(jì)模式,主要有制作月餅的工廠模式,結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì),需要的朋友可以參考下2022-09-09