2. 程式人生 > 其它 >從原始碼角度詳解Java的Callable介面

從原始碼角度詳解Java的Callable介面

阿新 • • 發佈：2021-07-28
摘要：本文從原始碼角度深入解析Callable介面。

本文分享自華為雲社群《深入解析Callable介面》，作者： 冰 河 。

本文純乾貨，從原始碼角度深入解析Callable介面，希望大家踏下心來，開啟你的IDE，跟著文章看原始碼，相信你一定收穫不小。

1.Callable介面介紹

Callable介面是JDK1.5新增的泛型介面，在JDK1.8中，被宣告為函式式介面，如下所示。

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

在JDK 1.8中只宣告有一個方法的介面為函式式介面，函式式介面可以使用@FunctionalInterface註解修飾，也可以不使用@FunctionalInterface註解修飾。只要一個介面中只包含有一個方法，那麼，這個介面就是函式式介面。

在JDK中，實現Callable介面的子類如下圖所示。

預設的子類層級關係圖看不清，這裡，可以通過IDEA右鍵Callable介面，選擇“Layout”來指定Callable介面的實現類圖的不同結構，如下所示。

這裡，可以選擇“Organic Layout”選項，選擇後的Callable介面的子類的結構如下圖所示。

在實現Callable介面的子類中，有幾個比較重要的類，如下圖所示。

分別是：Executors類中的靜態內部類：PrivilegedCallable、PrivilegedCallableUsingCurrentClassLoader、RunnableAdapter和Task類下的TaskCallable。

2.實現Callable介面的重要類分析

接下來，分析的類主要有：PrivilegedCallable、PrivilegedCallableUsingCurrentClassLoader、RunnableAdapter和Task類下的TaskCallable。雖然這些類在實際工作中很少被直接用到，但是作為一名合格的開發工程師，設定是禿頂的資深專家來說，瞭解並掌握這些類的實現有助你進一步理解Callable介面，並提高專業技能（頭髮再掉一批，哇哈哈哈。。。）。

  • PrivilegedCallable

PrivilegedCallable類是Callable介面的一個特殊實現類，它表明Callable物件有某種特權來訪問系統的某種資源，PrivilegedCallable類的原始碼如下所示。

/**
 * A callable that runs under established access control settings
 */
static final class PrivilegedCallable<T> implements Callable<T> {
    private final Callable<T> task;
    private final AccessControlContext acc;

    PrivilegedCallable(Callable<T> task) {
        this.task = task;
        this.acc = AccessController.getContext();
    }

    public T call() throws Exception {
        try {
            return AccessController.doPrivileged(
                new PrivilegedExceptionAction<T>() {
                    public T run() throws Exception {
                        return task.call();
                    }
                }, acc);
        } catch (PrivilegedActionException e) {
            throw e.getException();
        }
    }
}

從PrivilegedCallable類的原始碼來看，可以將PrivilegedCallable看成是對Callable介面的封裝，並且這個類也繼承了Callable介面。

在PrivilegedCallable類中有兩個成員變數，分別是Callable介面的例項物件和AccessControlContext類的例項物件，如下所示。

private final Callable<T> task;
private final AccessControlContext acc;

其中，AccessControlContext類可以理解為一個具有系統資源訪問決策的上下文類，通過這個類可以訪問系統的特定資源。通過類的構造方法可以看出，在例項化AccessControlContext類的物件時，只需要傳遞Callable介面子類的物件即可，如下所示。

PrivilegedCallable(Callable<T> task) {
    this.task = task;
    this.acc = AccessController.getContext();
}

AccessControlContext類的物件是通過AccessController類的getContext()方法獲取的，這裡，檢視AccessController類的getContext()方法，如下所示。

public static AccessControlContext getContext(){
    AccessControlContext acc = getStackAccessControlContext();
    if (acc == null) {
        return new AccessControlContext(null, true);
    } else {
        return acc.optimize();
    }
}

通過AccessController的getContext()方法可以看出，首先通過getStackAccessControlContext()方法來獲取AccessControlContext物件例項。如果獲取的AccessControlContext物件例項為空，則通過呼叫AccessControlContext類的構造方法例項化，否則，呼叫AccessControlContext物件例項的optimize()方法返回AccessControlContext物件例項。

這裡，我們先看下getStackAccessControlContext()方法是個什麼鬼。

private static native AccessControlContext getStackAccessControlContext();

原來是個本地方法，方法的字面意思就是獲取能夠訪問系統棧的決策上下文物件。

接下來，我們回到PrivilegedCallable類的call()方法，如下所示。

public T call() throws Exception {
    try {
        return AccessController.doPrivileged(
            new PrivilegedExceptionAction<T>() {
                public T run() throws Exception {
                    return task.call();
                }
            }, acc);
    } catch (PrivilegedActionException e) {
        throw e.getException();
    }
}

通過呼叫AccessController.doPrivileged()方法，傳遞PrivilegedExceptionAction。介面物件和AccessControlContext物件，並最終返回泛型的例項物件。

首先，看下AccessController.doPrivileged()方法，如下所示。

@CallerSensitive
public static native <T> T
    doPrivileged(PrivilegedExceptionAction<T> action,
                 AccessControlContext context)
    throws PrivilegedActionException;

可以看到，又是一個本地方法。也就是說，最終的執行情況是將PrivilegedExceptionAction介面物件和AccessControlContext物件例項傳遞給這個本地方法執行。並且在PrivilegedExceptionAction介面物件的run()方法中呼叫Callable介面的call()方法來執行最終的業務邏輯，並且返回泛型物件。

  • PrivilegedCallableUsingCurrentClassLoader

此類表示為在已經建立的特定訪問控制和當前的類載入器下執行的Callable類，原始碼如下所示。

/**
 * A callable that runs under established access control settings and
 * current ClassLoader
 */
static final class PrivilegedCallableUsingCurrentClassLoader<T> implements Callable<T> {
    private final Callable<T> task;
    private final AccessControlContext acc;
    private final ClassLoader ccl;

    PrivilegedCallableUsingCurrentClassLoader(Callable<T> task) {
        SecurityManager sm = System.getSecurityManager();
        if (sm != null) {
            sm.checkPermission(SecurityConstants.GET_CLASSLOADER_PERMISSION);
            sm.checkPermission(new RuntimePermission("setContextClassLoader"));
        }
        this.task = task;
        this.acc = AccessController.getContext();
        this.ccl = Thread.currentThread().getContextClassLoader();
    }

    public T call() throws Exception {
        try {
            return AccessController.doPrivileged(
                new PrivilegedExceptionAction<T>() {
                    public T run() throws Exception {
                        Thread t = Thread.currentThread();
                        ClassLoader cl = t.getContextClassLoader();
                        if (ccl == cl) {
                            return task.call();
                        } else {
                            t.setContextClassLoader(ccl);
                            try {
                                return task.call();
                            } finally {
                                t.setContextClassLoader(cl);
                            }
                        }
                    }
                }, acc);
        } catch (PrivilegedActionException e) {
            throw e.getException();
        }
    }
}

這個類理解起來比較簡單，首先，在類中定義了三個成員變數，如下所示。

private final Callable<T> task;
private final AccessControlContext acc;
private final ClassLoader ccl;

接下來，通過構造方法注入Callable物件，在構造方法中，首先獲取系統安全管理器物件例項，通過系統安全管理器物件例項檢查是否具有獲取ClassLoader和設定ContextClassLoader的許可權。並在構造方法中為三個成員變數賦值，如下所示。

PrivilegedCallableUsingCurrentClassLoader(Callable<T> task) {
    SecurityManager sm = System.getSecurityManager();
    if (sm != null) {
        sm.checkPermission(SecurityConstants.GET_CLASSLOADER_PERMISSION);
        sm.checkPermission(new RuntimePermission("setContextClassLoader"));
    }
    this.task = task;
    this.acc = AccessController.getContext();
    this.ccl = Thread.currentThread().getContextClassLoader();
}

接下來，通過呼叫call()方法來執行具體的業務邏輯，如下所示。

public T call() throws Exception {
    try {
        return AccessController.doPrivileged(
            new PrivilegedExceptionAction<T>() {
                public T run() throws Exception {
                    Thread t = Thread.currentThread();
                    ClassLoader cl = t.getContextClassLoader();
                    if (ccl == cl) {
                        return task.call();
                    } else {
                        t.setContextClassLoader(ccl);
                        try {
                            return task.call();
                        } finally {
                            t.setContextClassLoader(cl);
                        }
                    }
                }
            }, acc);
    } catch (PrivilegedActionException e) {
        throw e.getException();
    }
}

在call()方法中同樣是通過呼叫AccessController類的本地方法doPrivileged，傳遞PrivilegedExceptionAction介面的例項物件和AccessControlContext類的物件例項。

具體執行邏輯為：在PrivilegedExceptionAction物件的run()方法中獲取當前執行緒的ContextClassLoader物件，如果在構造方法中獲取的ClassLoader物件與此處的ContextClassLoader物件是同一個物件（不止物件例項相同，而且記憶體地址也相同），則直接呼叫Callable物件的call()方法返回結果。否則，將PrivilegedExceptionAction物件的run()方法中的當前執行緒的ContextClassLoader設定為在構造方法中獲取的類載入器物件，接下來，再呼叫Callable物件的call()方法返回結果。最終將當前執行緒的ContextClassLoader重置為之前的ContextClassLoader。

  • RunnableAdapter

RunnableAdapter類比較簡單，給定執行的任務和結果，執行給定的任務並返回給定的結果，原始碼如下所示。

/**
 * A callable that runs given task and returns given result
 */
static final class RunnableAdapter<T> implements Callable<T> {
    final Runnable task;
    final T result;
    RunnableAdapter(Runnable task, T result) {
        this.task = task;
        this.result = result;
    }
    public T call() {
        task.run();
        return result;
    }
}
  • TaskCallable

TaskCallable類是javafx.concurrent.Task類的靜態內部類，TaskCallable類主要是實現了Callable介面並且被定義為FutureTask的類，並且在這個類中允許我們攔截call()方法來更新task任務的狀態。原始碼如下所示。

private static final class TaskCallable<V> implements Callable<V> {

    private Task<V> task;
    private TaskCallable() { }

    @Override 
    public V call() throws Exception {
        task.started = true;
        task.runLater(() -> {
            task.setState(State.SCHEDULED);
            task.setState(State.RUNNING);
        });
        try {
            final V result = task.call();
            if (!task.isCancelled()) {
                task.runLater(() -> {
                    task.updateValue(result);
                    task.setState(State.SUCCEEDED);
                });
                return result;
            } else {
                return null;
            }
        } catch (final Throwable th) {
            task.runLater(() -> {
                task._setException(th);
                task.setState(State.FAILED);
            });
            if (th instanceof Exception) {
                throw (Exception) th;
            } else {
                throw new Exception(th);
            }
        }
    }
}

從TaskCallable類的原始碼可以看出，只定義了一個Task型別的成員變數。下面主要分析TaskCallable類的call()方法。

當程式的執行進入到call()方法時，首先將task物件的started屬性設定為true，表示任務已經開始，並且將任務的狀態依次設定為State.SCHEDULED和State.RUNNING，依次觸發任務的排程事件和執行事件。如下所示。

task.started = true;
task.runLater(() -> {
    task.setState(State.SCHEDULED);
    task.setState(State.RUNNING);
});

接下來，在try程式碼塊中執行Task物件的call()方法，返回泛型物件。如果任務沒有被取消，則更新任務的快取，將呼叫call()方法返回的泛型物件繫結到Task物件中的ObjectProperty<V>物件中，其中，ObjectProperty<V>在Task類中的定義如下。

private final ObjectProperty<V> value = new SimpleObjectProperty<>(this, "value");

接下來，將任務的狀態設定為成功狀態。如下所示。

try {
    final V result = task.call();
    if (!task.isCancelled()) {
        task.runLater(() -> {
            task.updateValue(result);
            task.setState(State.SUCCEEDED);
        });
        return result;
    } else {
        return null;
    }
}

如果程式丟擲了異常或者錯誤，會進入catch()程式碼塊，設定Task物件的Exception資訊並將狀態設定為State.FAILED，也就是將任務標記為失敗。接下來，判斷異常或錯誤的型別，如果是Exception型別的異常，則直接強轉為Exception型別的異常並丟擲。否則，將異常或者錯誤封裝為Exception物件並丟擲，如下所示。

catch (final Throwable th) {
    task.runLater(() -> {
        task._setException(th);
        task.setState(State.FAILED);
    });
    if (th instanceof Exception) {
        throw (Exception) th;
    } else {
        throw new Exception(th);
    }
}

好了，今天就到這兒吧，我是冰河，我們下期見~~

點選關注，第一時間瞭解華為雲新鮮技術~

相關推薦

從原始碼角度詳解Java的Callable介面

摘要：本文從原始碼角度深入解析Callable介面。 本文分享自華為雲社群《深入解析Callable介面》，作者： 冰 河 。

Redis原始碼解析:叢集手動故障轉移、從節點遷移詳解

一：手動故障轉移 Redis叢集支援手動故障轉移。也就是向從節點發送”CLUSTER FAILOVER”命令，使其在主節點未下線的情況下，發起故障轉移流程，升級為新的主節點，而原來的主節點降級為從節點。

Python requests模組基礎使用方法例項及高階應用(自動登陸,抓取網頁原始碼)例項詳解

1、Python requests模組說明 requests是使用Apache2 licensed 許可證的HTTP庫。 用python編寫。

詳解java介面（interface）在不同JDK版本中的變化

JDK1.7以及以前： 介面（interface）在JDK7及之前的版本對介面的要求： 介面定義：

精通SpringBoot-詳解WebMvcConfigurer介面

SpringBoot 確實為我們做了很多事情， 但有時候我們想要自己定義一些Handler，Interceptor，ViewResolver，MessageConverter，該怎麼做呢。在Spring Boot 1.5版本都是靠重寫WebMvcConfigurerAdapter的方法來新增自定

從原始碼角度來剖析ThreadLocal到底有沒有記憶體洩漏？

1. 前言 ThreadLocal 也是一個使用頻率較高的類，在框架中也經常見到，比如 Spring。

詳解c# 介面IDisposable的用法

　　C#的每一個型別都代表一種資源，而資源又分為兩類： 託管資源 由CLR管理分配和釋放的資源，即從CLR裡new出來的物件。

c欄位和屬性的區別_從原始碼角度理解Mybatis欄位對映

技術標籤：c欄位和屬性的區別mybatis plus 動態建立表和欄位mybatis resulttype型別mybatis將欄位改為nulltemplet 顯示欄位外來鍵對應名為什麼要預留欄位

從原始碼角度學習Java動態代理

公眾號文章連結：https://mp.weixin.qq.com/s/jaLvb21yVHg2R_gJ-JSeVA 前言 最近，看了一下關於RMI(Remote Method Invocation)相關的知識，遇到了一個動態代理的問題，然後就決定探究一下動態代理。

Java基礎進階:時間類要點摘要,時間Date類實現格式化與解析原始碼實現詳解,LocalDateTime時間類格式化與解析原始碼實現詳解,Period,Duration獲取時間間隔與原始碼實現,程式異常解析與處理方式

　　　　　　　　　　　　　　　　　　　　　　 　　　　　　　　　　　　　　　　　　　　要點摘要

Python日誌列印裡logging.getLogger原始碼分析詳解

實踐環境 WIN 10 Python 3.6.5 函式說明 logging.getLogger(name=None) getLogger函式位於logging/__init__.py指令碼

從原始碼角度來回答keep-alive元件的快取原理

今天開門見山地聊一下面試中被問到的一個問題：keep-alive元件的快取原理。 官方API介紹和用法

詳解PHP介面簽名驗證

概覽 在設計簽名驗證的時候，一定要滿足以下幾點： 可變性：每次的簽名必須是不一樣的。

AbstractQueuedSynchronizer(AQS)原始碼分析詳解

AbstractQueuedSynchronizer 是一個抽象的同步等待佇列。juc下面多大多數鎖都是使用到了AQS。除了獲取資源和釋放資源的方法外，AQS基本上將其他同步等待佇列的邏輯都實現了，比如現場進入佇列同步等待、相應中斷、喚

Vue之vue.$set()方法原始碼案例詳解

在使用開發專案的過程中，經常會遇到這樣的問題：當vue的data裡邊宣告或者已經賦值過的物件或者陣列（數組裡邊的值是物件）時，向物件中新增新的屬性，如果更新此屬性的值，是不會更新檢視的。

詳解Go 介面的作用

一、介面是什麼 interface是一組method簽名的組合，我們通過interface來定義物件的一組行為。

詳解java介面interface

引言 介面這個詞在生活中我們並不陌生。 在中國大陸，我們可以將自己的家用電器的插頭插到符合它插口的插座上；

又有新驚喜 困難·幽夜戰從龍技能詳解

經過了普通難度“幽夜戰從龍”的洗禮，相信各位少俠已經對該系列話本的機制有了初步瞭解。而大家即將挑戰的困難·幽夜戰從龍話本則又給諸位少俠帶來了一些新驚喜。困難本在普通本的基礎上，增加了一些技能，也微調了

精打細算偷輸出 英雄·幽夜戰從龍通關詳解

相較於困難本，英雄本並沒有什麼新增技能，在技能機制上的變化也很小。但因為英雄難度中增加了挑戰限時，更加考驗少俠們的輸出能力。

從原始碼角度分析建立執行緒池究竟有哪些方式

大家好，我是冰河~~ 在Java的高併發領域，執行緒池一直是一個繞不開的話題。有些童鞋一直在使用執行緒池，但是，對於如何建立執行緒池僅僅停留在使用Executors工具類的方式，那麼，建立執行緒池究竟存在哪幾種方式呢