泛型Java类中的泛型类型参数化线程池使用

在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方法来关闭线程池。