快捷導(dǎo)航

Java使用Callable接口實(shí)現(xiàn)多線程的實(shí)例代碼

更新時(shí)間：2023年08月26日 10:07:41 作者：Rooker

這篇文章主要介紹了Java使用Callable接口實(shí)現(xiàn)多線程的實(shí)例代碼,實(shí)現(xiàn)Callable和實(shí)現(xiàn)Runnable類似,但是功能更強(qiáng)大,具體表現(xiàn)在可以在任務(wù)結(jié)束后提供一個(gè)返回值,Runnable不行,call方法可以拋出異,Runnable的run方法不行,需要的朋友可以參考下

通過(guò)Callable接口實(shí)現(xiàn)多線程

實(shí)現(xiàn)Callable重寫call方法

實(shí)現(xiàn)Callable和實(shí)現(xiàn)Runnable類似，但是功能更強(qiáng)大，具體表現(xiàn)在

可以在任務(wù)結(jié)束后提供一個(gè)返回值，Runnable不行
call方法可以拋出異常，Runnable的run方法不行
可以通過(guò)運(yùn)行Callable得到的Fulture對(duì)象監(jiān)聽目標(biāo)線程調(diào)用call方法的結(jié)果，得到返回值，（fulture.get(),調(diào)用后會(huì)阻塞，直到獲取到返回值）

1.Callable接口介紹：

（1）java.util.concurrent.Callable是一個(gè)泛型接口，只有一個(gè)call()方法

（2）call()方法拋出異常Exception異常，且返回一個(gè)指定的泛型類對(duì)象

2.Callable接口實(shí)現(xiàn)多線程的應(yīng)用場(chǎng)景

當(dāng)父線程想要獲取子線程的運(yùn)行結(jié)果時(shí)

3.使用Callable接口實(shí)現(xiàn)多線程的步驟

（1）第一步：創(chuàng)建Callable子類的實(shí)例化對(duì)象

（2）第二步：創(chuàng)建FutureTask對(duì)象，并將Callable對(duì)象傳入FutureTask的構(gòu)造方法中（注意：FutureTask實(shí)現(xiàn)了Runnable接口和Future接口）

(3)第三步：實(shí)例化Thread對(duì)象，并在構(gòu)造方法中傳入FurureTask對(duì)象

(4)第四步：?jiǎn)?dòng)線程

例1（利用Callable接口實(shí)現(xiàn)線程）

利用Callable接口創(chuàng)建子線程類：

package com.my.frame;
import java.util.concurrent.Callable;
public class ThreadCall implements Callable<String> {
    @Override
    public String call() throws Exception {
        // TODO Auto-generated method stub
        System.out.println("=====");
        return "9999";
    }
}

package com.my.frame;
import java.util.concurrent.FutureTask;
public class TestThread {
    public static void main(String[] args) {
        FutureTask<String> ft = new FutureTask<>(new ThreadCall());
        new Thread(ft).start();
    }
}

例2（匿名類部類實(shí)現(xiàn)Callable接口創(chuàng)建子線程）

匿名類部類實(shí)現(xiàn)Callable接口創(chuàng)建子線程類并實(shí)現(xiàn)：

package call;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
//匿名類部類實(shí)現(xiàn)Callable接口創(chuàng)建子線程
public class AnonyCallable {
    public static void main(String[] args) {
    Callable<String> cl = new Callable<String>() {
    @Override
    public String call() throws Exception {
            System.out.println(Thread.currentThread().getName() + "正在行軍~~~");
            System.out.println(Thread.currentThread().getName() + "遭遇敵軍~~~");
            System.out.println(Thread.currentThread().getName() + "奮勇殺敵?。。?！");
            return "戰(zhàn)斗勝利，俘虜敵軍50000人";
            }
};
        FutureTask<String> ft = new FutureTask(cl);
        new Thread(ft, "李存孝部隊(duì)").start();
try {
        Thread.currentThread().setName("李存勖部隊(duì)");
        Thread.sleep(3000);
        System.out.println(Thread.currentThread().getName() + "休整3000ms");
} catch (InterruptedException e) {
    e.printStackTrace();
}
    System.out.println(Thread.currentThread().getName() + "整頓完畢，等待友軍消息...");
try {
            String str = ft.get();
            System.out.println("李存勖部隊(duì)得知友軍消息為：" + str);
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
    }
}
}

到此這篇關(guān)于Java使用Callable接口實(shí)現(xiàn)多線程的實(shí)例代碼的文章就介紹到這了,更多相關(guān)Java使用Callable接口實(shí)現(xiàn)多線程內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: