java threadpoolexecutor

import java.util.concurrent.*;

public class ThreadPoolExecutorExample {
    public static void main(String[] args) {
        // 创建一个线程池，核心线程数为2，最大线程数为4，空闲线程存活时间为60秒，使用LinkedBlockingQueue作为任务队列
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
            2, 
            4, 
            60L, 
            TimeUnit.SECONDS, 
            new LinkedBlockingQueue<>()
        );

        // 提交多个任务给线程池执行
        for (int i = 0; i < 10; i++) {
            int taskId = i;
            executor.submit(() -> {
                System.out.println("Executing task " + taskId + " by thread " + Thread.currentThread().getName());
                try {
                    // 模拟任务执行时间
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + taskId + " completed");
            });
        }

        // 关闭线程池
        executor.shutdown();
        try {
            // 等待所有任务完成
            if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
                executor.shutdownNow();
            }
        } catch (InterruptedException e) {
            executor.shutdownNow();
        }
    }
}

解释说明：

1. 创建线程池：我们使用ThreadPoolExecutor来创建一个自定义的线程池。线程池的核心线程数为2，最大线程数为4，空闲线程存活时间为60秒，使用LinkedBlockingQueue作为任务队列。
2. 提交任务：通过submit方法向线程池提交10个任务，每个任务会打印当前执行的任务ID和执行该任务的线程名称，并模拟2秒的任务执行时间。
3. 关闭线程池：调用shutdown方法来关闭线程池，然后使用awaitTermination等待所有任务完成。如果在指定时间内未能完成所有任务，则调用shutdownNow强制关闭线程池。