如何创建一个线程池

旧城等待， 2022-10-09 12:15 162阅读 0赞

### 什么是Java线程池？ ###

线程池就是提前创建若干个线程，如果有任务需要处理，线程池里的线程就会处理任务，处理完之后线程并不会被销毁，而是等待下一个任务。由于创建和销毁线程都是消耗系统资源的，所以当你想要频繁的创建和销毁线程的时候就可以考虑使用线程池来提升系统的性能。

### 为什么要使用线程池？ ###

1、创建/销毁线程伴随着系统开销，过于频繁的创建/销毁线程，会很大程度上影响处理效率

例如：

记创建线程消耗时间T1，执行任务消耗时间T2，销毁线程消耗时间T3

如果T1+T3>T2，那么是不是说开启一个线程来执行这个任务太不划算了！

正好，线程池缓存线程，可用已有的闲置线程来执行新任务，避免了T1+T3带来的系统开销

2、线程并发数量过多，抢占系统资源从而导致阻塞

我们知道线程能共享系统资源，如果同时执行的线程过多，就有可能导致系统资源不足而产生阻塞的情况。运用线程池能有效的控制线程最大并发数，避免以上的问题

3、对线程进行一些简单的管理。比如：延时执行、定时循环执行的策略等。运用线程池都能进行很好的实现

### Java有多少种线程池？ ###

常见的线程池有四种：  
**newCachedThreadPool()（可缓存线程池)**  
1.线程数无限制；

2.有空闲线程则复用空闲线程，若无空闲线程则新建线程；

3.一定程序减少频繁创建/销毁线程，减少系统开销

4.同时在线程池中如果一个线程60秒之内没有被使用过，这个线程就会被销毁。

**newFixedThreadPool(int)（定长线程池）**

1.可控制线程最大并发数（同时执行的线程数）

2.超出的线程会在队列中等待

3.int参数表示创建线程池内线程的数量

**newScheduledThreadPool()（定长线程池）**

1.创建一个定长线程池，支持定时及周期性任务执行

**newSingleThreadExecutor()（单线程化的线程池）**

1.有且仅有一个工作线程执行任务

2.所有任务按照指定顺序执行，即遵循队列的入队出队规则

### 线程池示例 ###

创建线程池的步骤：  
1、创建一个任务对象(实现Runnable接口)，用于执行具体的任务逻辑  
2、使用Executors创建线程池ExecutorService  
3、将待执行的任务对象交给ExecutorService进行任务处理  
4、停掉 Executor 线程池

需要使用到的maven坐标

<dependency>
                <groupId>com.google.guava</groupId>
                <artifactId>guava</artifactId>
                <version>27.0-jre</version>
            </dependency>

package com.mybatisplus.demo;
    
    import org.assertj.core.util.DateUtil;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    /** * @author huiXing * @version 1.0.0 * @description 如何创建一个线程池 */
    public class MyThread { 
    
        private static void createFixedThreadPool() { 
            //创建一个线程池
           ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("thread-call-runner-%d").build();
            int size = 3;//包含3个线程对象
            ExecutorService executorService = new ThreadPoolExecutor(size,size,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>(),namedThreadFactory);
    
            for (int i = 0; i < 10; i++) { 
                final int index = i;
                executorService.execute(() -> { 
                    // 获取线程名称,默认格式:pool-1-thread-1
                    System.out.println(DateUtil.now() + " " + Thread.currentThread().getName() + " " + index);
                    // 等待2秒
                    try { 
                        Thread.sleep(2000);
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    }
                });
            }
    
            //关闭线程池
            executorService.shutdown();
        }
        public static void main(String[] args) { 
            createFixedThreadPool();
        }
    }

运行结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NzM5NzA2_size_16_color_FFFFFF_t_70]  
案例2：

package com.mybatisplus.demo;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    /** * @author huiXing * @version 1.0.0 * @description 如何创建一个线程池 */
    public class MyThread implements Runnable{ 
    
        //线程的名字
        private String name;
    
        public MyThread(){ }
    
        public MyThread(String s){ 
            name = s;
        }
    
    
        @Override
        public void run() { 
            try{ 
                for (int i = 0; i<=5; i++) { 
                    if (i==0) { 
                        //第一次执行的时候，打印每一个任务的名称及初始化的时间
                        System.out.println(new SimpleDateFormat("yyyy/MM/dd HH:mm: ss").format(new Date())+"任务初始化" + name);
                    }
                    else{ 
    
                        System.out.println(new SimpleDateFormat("yyyy/MM/dd HH:mm: ss").format(new Date())+"任务正在执行" + name);
                        // 打印每一个任务处理的执行时间
                    }
    
                    Thread.sleep(1000);
                }
    
                System.out.println("任务执行完成" + name);
    
            }  catch(InterruptedException e)  { 
                e.printStackTrace();
            }
        }
    
        // 线程池里面最大线程数量
        static final int MAX_SIZE = 3;
    
        public static void main(String[] args) { 
    
                // 创建5个任务
                Runnable r1 = new MyThread("task 1");
                Runnable r2 = new MyThread("task 2");
                Runnable r3 = new MyThread("task 3");
                Runnable r4 = new MyThread("task 4");
                Runnable r5 = new MyThread("task 5");
    
                // 第二步：创建一个固定线程数量的线程池，线程数为MAX_SIZE
                ExecutorService pool = Executors.newFixedThreadPool(MAX_SIZE);
    
                // 第三步：将待执行的任务对象交给ExecutorService进行任务处理
                pool.execute(r1);
                pool.execute(r2);
                pool.execute(r3);
                pool.execute(r4);
                pool.execute(r5);
    
                // 第四步：关闭线程池
                pool.shutdown();
        }
    }

执行的结果：

2021/06/24 17:01: 25任务初始化task 3
    2021/06/24 17:01: 25任务初始化task 1
    2021/06/24 17:01: 25任务初始化task 2
    2021/06/24 17:01: 26任务正在执行task 2
    2021/06/24 17:01: 26任务正在执行task 3
    2021/06/24 17:01: 26任务正在执行task 1
    2021/06/24 17:01: 27任务正在执行task 1
    2021/06/24 17:01: 27任务正在执行task 3
    2021/06/24 17:01: 27任务正在执行task 2
    2021/06/24 17:01: 28任务正在执行task 1
    2021/06/24 17:01: 28任务正在执行task 2
    2021/06/24 17:01: 28任务正在执行task 3
    2021/06/24 17:01: 29任务正在执行task 3
    2021/06/24 17:01: 29任务正在执行task 1
    2021/06/24 17:01: 29任务正在执行task 2
    2021/06/24 17:01: 30任务正在执行task 1
    2021/06/24 17:01: 30任务正在执行task 2
    2021/06/24 17:01: 30任务正在执行task 3
    任务执行完成task 2
    任务执行完成task 1
    任务执行完成task 3
    2021/06/24 17:01: 31任务初始化task 4
    2021/06/24 17:01: 31任务初始化task 5
    2021/06/24 17:01: 32任务正在执行task 4
    2021/06/24 17:01: 32任务正在执行task 5
    2021/06/24 17:01: 33任务正在执行task 5
    2021/06/24 17:01: 33任务正在执行task 4
    2021/06/24 17:01: 34任务正在执行task 5
    2021/06/24 17:01: 34任务正在执行task 4
    2021/06/24 17:01: 35任务正在执行task 5
    2021/06/24 17:01: 35任务正在执行task 4
    2021/06/24 17:01: 36任务正在执行task 4
    2021/06/24 17:01: 36任务正在执行task 5
    任务执行完成task 4
    任务执行完成task 5

参考大佬博客：  
[https://www.cnblogs.com/zimug/p/14275379.html?share\_token=aa3913c2-2dc1-4b7a-b33f-29e53a7cde18][https_www.cnblogs.com_zimug_p_14275379.html_share_token_aa3913c2-2dc1-4b7a-b33f-29e53a7cde18]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NzM5NzA2_size_16_color_FFFFFF_t_70]: /images/20221005/46fd31d48fd24b3b95855d4c9e1c8dee.png
[https_www.cnblogs.com_zimug_p_14275379.html_share_token_aa3913c2-2dc1-4b7a-b33f-29e53a7cde18]: https://www.cnblogs.com/zimug/p/14275379.html?share_token=aa3913c2-2dc1-4b7a-b33f-29e53a7cde18