Java并发编程：线程池创建及使用示例

原创柔情只为你懂 2024-11-30 15:57 52阅读 0赞

在Java中，线程池是一种管理和复用线程的机制。以下是如何创建和使用线程池的简单示例：

1. 创建线程池（ThreadPoolExecutor）

```java
// 线程池参数
int corePoolSize = 5; // 核心线程数
int maximumPoolSize = 10; // 最大线程数
long keepAliveTime = 60L; // 空闲线程存活时间

// 创建线程池实例
ThreadPoolExecutor executor = new ThreadPoolExecutor(
    corePoolSize, // 核心线程池大小
    maximumPoolSize, // 最大线程池大小
    keepAliveTime, TimeUnit.MILLISECONDS, // 空闲线程存活时间
    new LinkedBlockingQueue<>(), // 工作队列，用于任务的分配与执行
    new ThreadFactory() { // 线程工厂，用于创建新线程
        @Override
        public Thread newThread(Runnable r) {
            // 设置线程名称
            Thread t = new Thread(r, "Task-" + r.hashCode()));
            return t;
        }
    },
    new RejectedExecutionHandler() { // 线程池拒绝策略，当工作队列满时，如何处理新任务的拒绝
        @Override
        public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
            // 输出拒绝信息
            System.out.println("Task rejection: " + r.toString());
        }
    }
);

// 设置线程池关闭后，如何处理还在执行中的任务
executor.setTerminationPolicy(new Policy() {
    @Override
    public void execute(Runnable command) {
        command.run(); // 执行命令
    }

@Override
    public boolean isTerminationPolicySupported(ThreadExecutor executor) {
        return true;
    }
}));

// 使用线程池
executor.execute(new Runnable() {
    @Override
    public void run() {
        // 这里可以执行任何任务，比如IO操作、计算等
        System.out.println("Task executed by thread: " + Thread.currentThread().getName());
    }
}));
```

2. 使用线程池（Lambda表达式）

```java
// 创建线程池
ThreadPoolExecutor executor = new ThreadPoolExecutor(
    corePoolSize, // 核心线程池大小
    maximumPoolSize, // 最大线程池大小
    keepAliveTime, TimeUnit.MILLISECONDS, // 空闲线程存活时间
    new LinkedBlockingQueue<>(), // 工作队列，用于任务的分配与执行
    executor::newTaskFor // 使用lambda表达式创建新线程的任务工厂
);

// 使用线程池
executor.execute(() -> {
    // 这里可以执行任何任务
    System.out.println("Task executed by lambda: " + Thread.currentThread().getName());
});
```

以上就是如何在Java中创建和使用线程池的简单示例。