您好,登錄后才能下訂單哦!
在Java中,我們可以使用泛型來創建線程池,這樣可以提高代碼的可重用性和類型安全。下面是一個使用泛型類型參數化線程池的示例:
import java.util.concurrent.*;
public class GenericThreadPool<T> {
private ThreadPoolExecutor executor;
public GenericThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
}
public void execute(Callable<T> task) throws InterruptedException {
Future<T> future = executor.submit(task);
// 可以在這里處理future,例如獲取任務執行結果
}
public <U> void execute(Runnable task, U result) {
executor.execute(() -> {
try {
task.run();
} finally {
// 將結果傳遞給任務執行者
((Consumer<U>) task).accept(result);
}
});
}
public void shutdown() {
executor.shutdown();
}
public List<Runnable> shutdownNow() {
return executor.shutdownNow();
}
public boolean isShutdown() {
return executor.isShutdown();
}
public boolean isTerminated() {
return executor.isTerminated();
}
public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
return executor.awaitTermination(timeout, unit);
}
}
在這個示例中,我們創建了一個名為GenericThreadPool
的泛型類,它接受一個類型參數T
。這個類使用ThreadPoolExecutor
來創建一個線程池,并提供了execute
方法來提交任務。execute
方法有兩個重載版本,一個接受Callable<T>
類型的任務,另一個接受Runnable
類型的任務和結果。
要使用這個泛型線程池,你可以像下面這樣創建一個實例:
public class Main {
public static void main(String[] args) {
GenericThreadPool<String> stringThreadPool = new GenericThreadPool<>(
2, 4, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<>(10)
);
// 提交Callable任務
stringThreadPool.execute(() -> {
System.out.println("Hello, " + Thread.currentThread().getName());
return "Task result";
});
// 提交Runnable任務并傳遞結果
stringThreadPool.execute(() -> {
System.out.println("Another task");
}, "Result for another task");
// 關閉線程池
stringThreadPool.shutdown();
}
}
這個示例中,我們創建了一個GenericThreadPool
實例,用于處理String
類型的結果。我們提交了一個Callable
任務和一個Runnable
任務,并在提交Runnable
任務時傳遞了一個結果。最后,我們調用shutdown
方法來關閉線程池。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。