线程池（关于变量捕获、线程数、针对ThreadPoolExecutor的构造方法参数的解释、自实现线程池）

╰+哭是因爲堅強的太久メ 2024-03-30 15:36 17阅读 0赞

## 目录： ##

##### 一、前言 #####

##### 二、关于变量捕获 #####

##### 三、针对ThreadPoolExecutor的构造方法参数的解释 #####

##### 四、自实现线程池 #####

--------------------

## 一、前言 ##

相比较于进程，创建线程 / 销毁线程 的开销是相对较小的，但是太过频繁的创建线程 / 销毁线程，其开销也很大。这时候我们就需要使用线程池来减少每次启动和销毁线程的损耗。事先把需要使用的线程先创建好，然后放到线程池中，后面需要使用的时候，直接从池里面获取，如果用完了就还给池。

## 二、关于变量捕获 ##

public static void main(String[] args) {
            ExecutorService pool = Executors.newFixedThreadPool(10);
            for (int i = 0; i < 1000; i++) {
                int n = i;
                pool.submit(new Runnable() {
                    @Override
                    public void run() {
                        //注意这里使用的是n,而不是i
                        System.out.println("hello " + n);
                    }
                });
            }
        }

这里for循环里面的变量 i 是主线程里的局部变量 (在主线程的栈上)，随着主线程这里的代码块执行结束就销毁了，很可能主线程这里for执行完了,当前run的任务在线程池里还没排到,此时i就已经要销毁了。这里就是一个变量捕获，很明显,此处的run方法属于Runnable。这个方法的执行时机,不是立刻马上而是在未来的某个节点(后续在线程池的队列中,排到他了,就让对应的线程去执行)。为了避免作用域的差异,导致后续执行run的时候i已经销毁,于是就有了变量捕获,也就是让run方法把刚才主线程的i给往当前run的栈上拷贝一份。

## 三、针对ThreadPoolExecutor的构造方法参数的解释 ##

API文档：[https://docs.oracle.com/javase/8/docs/api/][https_docs.oracle.com_javase_8_docs_api]

![a2d14e9aa81e435f83b849d1d066383a.png][]

1.  corePoolSize 核心线程数

1.  maximumPoolSize 最大线程数

ThreadPoolExecutor相当于把里面的线程分成两类:一类是正式员工(核心线程)，一类是临时工（除核心线程外的线程），这两者之和就是最大线程数，核心线程理论上是可以摸鱼的，但是临时工不可以摸鱼，临时工摸鱼有时间限制，一旦超过了keepAliveTime规定的摸鱼时间，那么就会被销毁。

1.  keepAliveTime，unit 除核心线程外的线程数可以休息的时间（临时工可以摸鱼的最大时间）

1.  [**BlockingQueue**][BlockingQueue]<[**Runnable**][Runnable]> workQueue 线程池的任务队列

1.  [**ThreadFactory**][ThreadFactory] threadFactory 线程工厂，用于创建线程

1.  [**RejectedExecutionHandler**][RejectedExecutionHandler] handler 描述了线程池的拒绝策略

![d538fdeaed6a4a0c9c37656c7605a520.png][]

**拒绝策略1：**[**ThreadPoolExecutor.AbortPolicy**][ThreadPoolExecutor.AbortPolicy]**（如果任务队列满了，就直接抛出异常）**

**拒绝策略2：**[**ThreadPoolExecutor.CallerRunsPolicy**][ThreadPoolExecutor.CallerRunsPolicy]**（如果队列满了，多出来的任务，是哪个线程加的，就由谁负责）**

**拒绝策略3：**[**ThreadPoolExecutor.DiscardOldestPolicy**][ThreadPoolExecutor.DiscardOldestPolicy]**（如果队列满了，就抛弃最早的任务，接受最新的任务）**

**拒绝策略4：**[**ThreadPoolExecutor.DiscardPolicy**][ThreadPoolExecutor.DiscardPolicy]**（如果队列满了，就抛弃最新的任务）**

## 四、自实现线程池 ##

class MyThreadPoll{
        private BlockingQueue<Runnable> queue = new LinkedBlockingDeque<>();
    
        public MyThreadPoll(int n){
            //创建线程
            for (int i = 0; i < n; i++) {
                Thread t = new Thread(()->{
                    while (true){
                        try {
                            Runnable runnable = queue.take();
                            runnable.run();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                });
                t.start();
            }
        }
    
        //注册任务给线程池
        public void submit(Runnable runnable){
            try {
                queue.put(runnable);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    public class ThreadDemo26 {
        public static void main(String[] args) {
            MyThreadPoll poll = new MyThreadPoll(10);
            for (int i = 0; i < 1000; i++) {
                int n = i;
                poll.submit(new Runnable() {
                    @Override
                    public void run() {
                        System.out.println("hello"+n);
                    }
                });
            }
        }
    }

[https_docs.oracle.com_javase_8_docs_api]: https://docs.oracle.com/javase/8/docs/api/
[a2d14e9aa81e435f83b849d1d066383a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/12c83b5040b74c6b90e3f253f1e2ec1f.png
[BlockingQueue]: https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html
[Runnable]: https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html
[ThreadFactory]: https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadFactory.html
[RejectedExecutionHandler]: https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/RejectedExecutionHandler.html
[d538fdeaed6a4a0c9c37656c7605a520.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/7f3fde20a3854b30b53868ba13d6680f.png
[ThreadPoolExecutor.AbortPolicy]: https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.AbortPolicy.html
[ThreadPoolExecutor.CallerRunsPolicy]: https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.CallerRunsPolicy.html
[ThreadPoolExecutor.DiscardOldestPolicy]: https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.DiscardOldestPolicy.html
[ThreadPoolExecutor.DiscardPolicy]: https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.DiscardPolicy.html