Java中的Callable實現(xiàn)多線程詳解

更新時間：2023年08月26日 10:09:26 作者：Orange#

這篇文章主要介紹了Java中的Callable實現(xiàn)多線程詳解,接口Callable中有一個call方法,其返回值類型為V,這是一個泛型,值得關注的是這個call方法有返回值,這意味著線程執(zhí)行完畢后可以將處理結(jié)果返回,需要的朋友可以參考下

Java中的Callable實現(xiàn)多線程

從Java提供多線程開始，最初的方案就是依靠Runnable接口定義線程類核心功能，但是Runnable中的run方法有一個缺點：該方法沒有返回值。

從JDK1.5開始，在JUC（java.util.concurrent）包中提供了一個新的多線程實現(xiàn)接口：

@FunctionalInterface
public interface Callable<V>{
    public V call() throws Exception;
}

接口Callable中有一個call方法，其返回值類型為V，這是一個泛型。

值得關注的是這個call方法有返回值，這意味著線程執(zhí)行完畢后可以將處理結(jié)果返回。

根據(jù)以往的套路，我們要創(chuàng)建一個實現(xiàn)Callable的的類，將其作為線程主體，這個類要覆寫call方法（其實call方法和run方法類似）：

class MyThread4 implements Callable<String>{ // 定義核心業(yè)務類
	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 + "線程運行， x = " + i);
		}
		return "執(zhí)行完畢";  // 返回值
	}
}

定義好了相應的線程執(zhí)行類，就要用Thread的start()方法啟動線程，但是表面上看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中有一個get()方法，注意：這個get()方法可以獲取callable方法的返回值。

那現(xiàn)在我們可以獲取Callable的返回值，但是，依舊看不出和Thread的關系。

2、再回到java.util.concurrent包中，找到RunnableFuture<V>

public interface RunnableFuture<V>
extends Runnable, Future<V>{
    void run();
}

這里我們先不關注run()方法，注意接口RunnableFuture繼承了接口Runnable和接口Future<V>。

3、查看Runnable的實現(xiàn)類，發(fā)現(xiàn)了FutureTask<V>，F(xiàn)utureTask<V>有兩個構(gòu)造方法，我們關注其中一個：

public FutureTask(Callable<V> callable)

這個構(gòu)造方法可傳callable的實現(xiàn)類，而FutureTask又繼承了Runnable。

所以Callable傳給FutureTask，F(xiàn)utureTask又繼承了Runnable，F(xiàn)utureTask就能作為Runnable傳給Thread，start()方法就得以調(diào)用。

Callable與Runnable兩個多線程接口最大的差別在于Callable有返回值。

實際使用哪個要看具體的需求。

完整代碼：

class MyThread4 implements Callable<String>{ // 定義核心業(yè)務類
	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 + "線程運行， 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());
	}
}

到此這篇關于Java中的Callable實現(xiàn)多線程詳解的文章就介紹到這了,更多相關Java的Callable多線程內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: