Java线程池创建过程-蒲公英云

Java线程池创建过程

Myth丶恋晨 2024-02-05 07:26 118阅读 0赞

使用线程池提供的构造方法或工厂方法

在 Java 中，创建线程池可以使用 java.util.concurrent.Executors 类中提供的静态方法。以下是线程池的创建过程：

导入必要的类：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
```

选择合适的线程池类型：
Java 提供了几种线程池类型，你可以根据需求选择适合的类型。常见的线程池类型有：
- FixedThreadPool：固定大小的线程池，创建一个固定数量的线程并重用它们。
- CachedThreadPool：可缓存的线程池，根据需要创建新线程，如果线程池中的线程空闲，则重用它们。
- SingleThreadExecutor：单线程的线程池，只有一个工作线程在执行任务，保证所有任务按顺序执行。
创建线程池实例：
使用选择的线程池类型创建线程池实例。例如，创建一个固定大小为 10 的线程池：
```
ExecutorService executorService = Executors.newFixedThreadPool(10);
```
```
提交任务给线程池执行：
通过调用线程池实例的 submit() 方法，将任务提交给线程池执行。任务可以是实现了 Runnable 接口或 Callable 接口的对象。例如，提交一个实现了 Runnable 接口的任务：
```
executorService.submit(new MyRunnableTask());
```
```
关闭线程池：
当不再需要线程池时，应该显式关闭它，以释放资源。调用线程池实例的 shutdown() 方法来关闭线程池。例如：
```
executorService.shutdown();
```
```

这是一个简单的线程池创建过程。你可以根据具体的需求和场景进行配置和使用线程池。

自定义现线程池创建过程

要自定义创建线程池的过程，你可以使用ThreadPoolExecutor类的构造方法进行创建。以下是自定义线程池的创建过程的示例代码：

// 导入必要的库
import java.util.concurrent.*;
public class CustomThreadPoolExample {
    public static void main(String[] args) {
        // 创建线程池
        int corePoolSize = 5; // 核心线程数
        int maxPoolSize = 10; // 最大线程数
        long keepAliveTime = 60L; // 非核心线程的闲置超时时间（单位：秒）
        BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(100); // 任务队列
        ThreadFactory threadFactory = Executors.defaultThreadFactory(); // 线程工厂
        RejectedExecutionHandler rejectedExecutionHandler = new ThreadPoolExecutor.AbortPolicy(); // 拒绝策略
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                corePoolSize,
                maxPoolSize,
                keepAliveTime,
                TimeUnit.SECONDS,
                workQueue,
                threadFactory,
                rejectedExecutionHandler
        );
        // 提交任务给线程池
        executor.submit(new MyTask());
        // 关闭线程池
        executor.shutdown();
    }
}
class MyTask implements Runnable {
    @Override
    public void run() {
        // 执行任务的逻辑
        System.out.println("Executing task...");
    }
}