Java的MoreSuppliers工具類方法解析

更新時間：2024年01月16日 08:50:27 作者：加油當當

這篇文章主要介紹了Java的MoreSuppliers工具類方法解析,MoreSuppliers類是一個Java工具類,它提供了一些增強的Supplier函數(shù),使得Supplier執(zhí)行的結果可以被緩存,真正的調用只執(zhí)行一次,需要的朋友可以參考下

MoreSuppliers工具類

MoreSuppliers類是一個Java工具類，它提供了一些增強的Supplier函數(shù)，使得Supplier執(zhí)行的結果可以被緩存，真正的調用只執(zhí)行一次。

public static <T> CloseableSupplier<T> lazy(Supplier<T> delegate)：

這個方法返回一個懶加載的提供器，首次獲取值時通過delegate加載值，并緩存這個值，在后續(xù)獲取時直接返回這個緩存的值。這個方法的使用場景是當你有一個計算成本較高或者IO操作的Supplier，并且你希望只執(zhí)行一次這個操作，然后緩存結果以供后續(xù)使用。

示例：

Supplier<String> expensiveOperation = () -> {
    // Some expensive operation...
    return "result";
};
Supplier<String> lazySupplier = MoreSuppliers.lazy(expensiveOperation);
String result = lazySupplier.get();  // The expensive operation is performed here.
String cachedResult = lazySupplier.get();  // The cached result is returned here.

public static <T> CloseableSupplier<T> lazy(Supplier<T> delegate, boolean resetAfterClose)：

這個方法和上一個方法類似，但是它允許在關閉提供器返回的資源后，是否釋放緩存的對象。這個方法的使用場景是當你的Supplier返回的是一個需要關閉的資源，比如一個數(shù)據(jù)庫連接，你希望在關閉這個資源后，下次調用get()方法時重新獲取一個新的資源。

示例：

Supplier<Connection> connectionSupplier = () -> {
    // Get a connection from the database...
    return connection;
};
CloseableSupplier<Connection> lazySupplier = MoreSuppliers.lazy(connectionSupplier, true);
Connection connection = lazySupplier.get();  // The connection is obtained here.
lazySupplier.tryClose(Connection::close);  // The connection is closed here.
Connection newConnection = lazySupplier.get();  // A new connection is obtained here.

public static <T, X extends Throwable> CloseableThrowableSupplier<T, X> lazyEx(ThrowableSupplier<T, X> delegate)：

這個方法返回一個懶加載的提供器，支持異常類型聲明。這個方法的使用場景是當你的Supplier可能拋出一個異常，你希望這個異常能被正確地傳播出去。

示例：

ThrowableSupplier<String, IOException> ioOperation = () -> {
    // Some IO operation...
    return "result";
};
ThrowableSupplier<String, IOException> lazySupplier = MoreSuppliers.lazyEx(ioOperation);
try {
    String result = lazySupplier.get();  // The IO operation is performed here.
} catch (IOException e) {
    // Handle the exception...
}

public static <T, X extends Throwable> CloseableThrowableSupplier<T, X> lazyEx(ThrowableSupplier<T, X> delegate, boolean resetAfterClose)：

這個方法和上一個方法類似，但是它允許在關閉提供器返回的資源后，是否釋放緩存的對象。這個方法的使用場景是當你的Supplier返回的是一個需要關閉的資源并且可能拋出一個異常，你希望在關閉這個資源后，下次調用get()方法時重新獲取一個新的資源，并且異常能被正確地傳播出去。

示例：

ThrowableSupplier<Connection, SQLException> connectionSupplier = () -> {
    // Get a connection from the database...
    return connection;
};
CloseableThrowableSupplier<Connection, SQLException> lazySupplier = MoreSuppliers.lazyEx(connectionSupplier, true);
try {
    Connection connection = lazySupplier.get();  // The connection is obtained here.
    lazySupplier.tryClose(Connection::close);  // The connection is closed here.
    Connection newConnection = lazySupplier.get();  // A new connection is obtained here.
} catch (SQLException e) {
    // Handle the exception...
}

public static <T> AsyncSupplier<T> asyncLazyEx(Supplier<T> delegate, Supplier<T> pendingSupplier, String threadName)：

這個方法返回一個異步加載的提供器，通過異步線程來完成初始化操作，支持超時。當超過指定的時間沒有獲取初始值成功時，使用pendingSupplier提供的值作為托底。這個方法的使用場景是當你的Supplier需要花費較長的時間來獲取值，你希望這個操作能在一個單獨的線程中進行，而主線程可以繼續(xù)執(zhí)行其他任務。

示例：

Supplier<String> slowOperation = () -> {
    // Some slow operation...
    return "result";
};
Supplier<String> fallback = () -> "fallback";
AsyncSupplier<String> asyncSupplier = MoreSuppliers.asyncLazyEx(slowOperation, fallback, "InitThread");
String result = asyncSupplier.get(Duration.ofSeconds(5));  // The slow operation is performed in a separate thread. If it takes more than 5 seconds, the fallback value is returned.

public static <T> AsyncSupplier<T> asyncLazyEx(Supplier<T> delegate, String threadName)：

這個方法和上一個方法類似，但是它沒有提供托底的Supplier，如果異步初始化值超時，它將返回null。

示例：

Supplier<String> slowOperation = () -> {
    // Some slow operation...
    return "result";
};
AsyncSupplier<String> asyncSupplier = MoreSuppliers.asyncLazyEx(slowOperation, "InitThread");
String result = asyncSupplier.get(Duration.ofSeconds(5));  // The slow operation is performed in a separate thread. If it takes more than 5 seconds, null is returned.

public static <T> AsyncSupplier<T> asyncLazyEx(Supplier<T> delegate)：

這個方法和上一個方法類似，但是它沒有指定執(zhí)行初始化操作的線程名稱。

示例：

Supplier<String> slowOperation = () -> {
    // Some slow operation...
    return "result";
};
AsyncSupplier<String> asyncSupplier = MoreSuppliers.asyncLazyEx(slowOperation);
String result = asyncSupplier.get(Duration.ofSeconds(5));  // The slow operation is performed in a separate thread. If it takes more than 5 seconds, null is returned.

CloseableSupplier<T>：

這是一個可關閉的Supplier實現(xiàn)，支持通過tryClose(ThrowableConsumer<T, X>closer)方法關閉提供器返回的資源。

示例：

CloseableSupplier<Connection> connectionSupplier = MoreSuppliers.lazy(() -> {
    // Get a connection from the database...
    return connection;
}, true);
Connection connection = connectionSupplier.get();  // The connection is obtained here.
connectionSupplier.tryClose(Connection::close);  // The connection is closed here.

CloseableThrowableSupplier<T, X>：

這是一個可關閉的Supplier實現(xiàn)，支持異常類型聲明，通過tryClose(ThrowableConsumer<T, X> closer)方法關閉提供器返回的資源。

示例：

CloseableThrowableSupplier<Connection, SQLException> connectionSupplier = MoreSuppliers.lazyEx(() -> {
 
    // Get a connection from the database...
 
    return connection;
 
}, true);
 
try {
 
    Connection connection = connectionSupplier.get();  // The connection is obtained here.
 
    connectionSupplier.tryClose(Connection::close);  // The connection is closed here.
 
} catch (SQLException e) {
 
    // Handle the exception...
 
}

AsyncSupplier<T>：

這是一個異步加載的Supplier實現(xiàn)，通過異步線程來完成初始化操作，支持超時。當超過指定的時間沒有獲取初始值成功時，使用pendingSupplier提供的值作為托底。

示例：

Supplier<String> slowOperation = () -> {
    // Some slow operation...
    return "result";
};
Supplier<String> fallback = () -> "fallback";
AsyncSupplier<String> asyncSupplier = MoreSuppliers.asyncLazyEx(slowOperation, fallback, "InitThread");
String result = asyncSupplier.get(Duration.ofSeconds(5));  // The slow operation is performed in a separate thread. If it takes more than 5 seconds, the fallback value is returned.

到此這篇關于Java的MoreSuppliers工具類方法解析的文章就介紹到這了,更多相關MoreSuppliers工具類內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: