快捷導(dǎo)航

Java多線程實(shí)現(xiàn)之Callable詳解

更新時(shí)間：2023年08月26日 09:47:12 作者：not coder

這篇文章主要介紹了Java多線程實(shí)現(xiàn)之Callable詳解,Callable是一個(gè)接口,用于實(shí)現(xiàn)多線程,與實(shí)現(xiàn)Runnable類似,但是功能更強(qiáng)大,通過實(shí)現(xiàn)Callable接口,我們需要重寫call()方法,該方法可以在任務(wù)結(jié)束后提供一個(gè)返回值,需要的朋友可以參考下

Java多線程實(shí)現(xiàn)之Callable接口

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

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

例1：利用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：

        Callable<String> callable = new Callable<String>() {
            @Override
            public String call() throws Exception {
                try {
                    Thread.sleep(1500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                return "成功";
            }
        };
        ExecutorService executorService = Executors.newCachedThreadPool();
        Future<String> future = executorService.submit(callable);
        String result = null;
        try {
            result = future.get();
        } catch (ExecutionException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("result:" + result);

Callable 與 Runnable

都是以 able 結(jié)束，可以開啟線程

Callable 有返回值

那么現(xiàn)在就有一個(gè)問題，子現(xiàn)場(chǎng)是耗時(shí)操作的，他的返回值返回給誰用呢，主線程如何不阻塞的情況下拿到子線程的返回值呢？

我們接下來解釋這個(gè)問題

首先，executorService.submit(callable) 中，executor 調(diào)用的不是 execute(callable) 而是 submit(callable)

然后配合 future.get() 去取值，這里的取值，是阻塞式的，能保證我們值的可靠性，這是 Java 在 API 層能做到的上限了。

其中，future 提供一種方法讓主線程能夠主動(dòng)去詢問后臺(tái)線程是否執(zhí)行完畢，他就是：future.isDone()

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

您可能感興趣的文章: