Java线程池创建过程

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

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

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

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

上述示例代码演示了如何使用`ThreadPoolExecutor`类自定义线程池的创建过程。你可以根据需求调整以下参数：

*  `corePoolSize`：核心线程数，表示线程池中保持活动状态的线程数。
 *  `maxPoolSize`：最大线程数，表示线程池允许创建的最大线程数。
 *  `keepAliveTime`：非核心线程的闲置超时时间，超过该时间后，多余的非核心线程会被终止并从线程池中移除。
 *  `workQueue`：任务队列，用于保存待执行的任务。
 *  `threadFactory`：线程工厂，用于创建线程对象。
 *  `rejectedExecutionHandler`：拒绝策略，用于处理无法执行的任务。

在创建线程池后，你可以通过调用`submit()`方法向线程池提交任务，并通过`shutdown()`方法关闭线程池。

请注意，在使用自定义线程池时，你需要根据实际需求和系统资源进行合理的配置，以避免线程过多或过少的情况。