泛型Java類中的泛型類型參數(shù)化線程池使用

在Java中，我們可以使用泛型來創(chuàng)建線程池，這樣可以提高代碼的可重用性和類型安全。下面是一個(gè)使用泛型類型參數(shù)化線程池的示例：

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，例如獲取任務(wù)執(zhí)行結(jié)果
    }

    public <U> void execute(Runnable task, U result) {
        executor.execute(() -> {
            try {
                task.run();
            } finally {
                // 將結(jié)果傳遞給任務(wù)執(zhí)行者
                ((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);
    }
}

在這個(gè)示例中，我們創(chuàng)建了一個(gè)名為GenericThreadPool的泛型類，它接受一個(gè)類型參數(shù)T。這個(gè)類使用ThreadPoolExecutor來創(chuàng)建一個(gè)線程池，并提供了execute方法來提交任務(wù)。execute方法有兩個(gè)重載版本，一個(gè)接受Callable<T>類型的任務(wù)，另一個(gè)接受Runnable類型的任務(wù)和結(jié)果。

要使用這個(gè)泛型線程池，你可以像下面這樣創(chuàng)建一個(gè)實(shí)例：

public class Main {
    public static void main(String[] args) {
        GenericThreadPool<String> stringThreadPool = new GenericThreadPool<>(
                2, 4, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<>(10)
        );

        // 提交Callable任務(wù)
        stringThreadPool.execute(() -> {
            System.out.println("Hello, " + Thread.currentThread().getName());
            return "Task result";
        });

        // 提交Runnable任務(wù)并傳遞結(jié)果
        stringThreadPool.execute(() -> {
            System.out.println("Another task");
        }, "Result for another task");

        // 關(guān)閉線程池
        stringThreadPool.shutdown();
    }
}

這個(gè)示例中，我們創(chuàng)建了一個(gè)GenericThreadPool實(shí)例，用于處理String類型的結(jié)果。我們提交了一個(gè)Callable任務(wù)和一個(gè)Runnable任務(wù)，并在提交Runnable任務(wù)時(shí)傳遞了一個(gè)結(jié)果。最后，我們調(diào)用shutdown方法來關(guān)閉線程池。