谈谈线程池的三大方法

爱被打了一巴掌 2023-07-14 13:58 8阅读 0赞

### 文章目录 ###

*  为什么使用线程池？
 *  线程池如何使用？
 *   *  架构说明
     *  Executors.newFixedThreadPool(int nThreads)
     *   *  举例
     *  Executors.newSingleThreadExecutor()
     *  举例
     *  Executors.newCachedThreadPool()
     *   *  举例

# 为什么使用线程池？ #

线程池做的工作主要是控制运行的线程数量，处理过程中将任务放入队列，然后在线程创建后启动这个任务，如果线程数量超过了最大数量，超出数量的线程排队等候，等待其它线程执行完毕，再从队列中取出任务来执行

线程池的主要特点为：线程复用，控制最大并发数，管理线程

*  降低资源消耗，通过重读利用已创建的线程降低线程创建的销毁造成的消耗
 *  提高响应速度，当任务到达时，任务可以不需要等待线程的创建就能立即执行
 *  提高线程的可管理性，线程是稀缺资源，如果无限制的创建，不仅会消耗系统资源，还会降低系统的稳定性，使用线程池可以进行统一的分配，调优和监控

# 线程池如何使用？ #

## 架构说明 ##

Java 中的线程池是通过 Executor 框架来实现的，该框架中使用到了 Executor，Executors，ExecutorService，ThreadPoolExecutor 这几个类  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dvb19ob21l_size_16_color_FFFFFF_t_70]

## Executors.newFixedThreadPool(int nThreads) ##

执行长期任务性能好，创建一个线程池，一池有 N 个固定的线程，有固定线程数的线程

### 举例 ###

package juc;
    
    /** * @author Woo_home * @create by 2020/3/14 */
    public class MyThreadPoolDemo { 
        public static void main(String[] args) { 
            // 一个线程池 5 个工作线程，类似银行有 5 个受理窗口
            ExecutorService threadPool = Executors.newFixedThreadPool(5);
            try { 
                // 模拟有十个用户过来银行办理业务，目前池子里面有 5 个工作人员提供服务
                for (int i = 1; i <= 10; i++) { 
                    threadPool.execute(() -> { 
                        System.out.println(Thread.currentThread().getName() + " 办理业务");
                    });
                    TimeUnit.SECONDS.sleep(1);
                }
            } catch (Exception e) { 
                e.printStackTrace();
            } finally { 
                threadPool.shutdown();
            }
        }
    }

输出：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dvb19ob21l_size_16_color_FFFFFF_t_70 1]

## Executors.newSingleThreadExecutor() ##

一个任务一个任务地执行，一个线程池一个线程

## 举例 ##

package juc;
    
    /** * @author Woo_home * @create by 2020/3/14 */
    public class MyThreadPoolDemo { 
        public static void main(String[] args) { 
            // 一个线程池一个工作线程，类似银行有一个受理窗口
            ExecutorService threadPool = Executors.newCachedThreadPool();
            try { 
                // 模拟有十个用户过来银行办理业务，目前池子里面有 5 个工作人员提供服务
                for (int i = 1; i <= 10; i++) { 
                    threadPool.execute(() -> { 
                        System.out.println(Thread.currentThread().getName() + " 办理业务");
                    });
                    TimeUnit.SECONDS.sleep(1);
                }
            } catch (Exception e) { 
                e.printStackTrace();
            } finally { 
                threadPool.shutdown();
            }
        }
    }

输出：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dvb19ob21l_size_16_color_FFFFFF_t_70 2]

## Executors.newCachedThreadPool() ##

一个线程池 N 个工作线程，类似一个银行有 N 个受理窗口

### 举例 ###

package juc;
    
    /** * @author Woo_home * @create by 2020/3/14 */
    public class MyThreadPoolDemo { 
        public static void main(String[] args) { 
            // 一个线程池 N 个工作线程，类似银行有 N 个受理窗口
            ExecutorService threadPool = Executors.newCachedThreadPool();
            try { 
                // 模拟有十个用户过来银行办理业务，目前池子里面有 5 个工作人员提供服务
                for (int i = 1; i <= 10; i++) { 
                    TimeUnit.SECONDS.sleep(1);
                    threadPool.execute(() -> { 
                        System.out.println(Thread.currentThread().getName() + " 办理业务");
                    });
                }
            } catch (Exception e) { 
                e.printStackTrace();
            } finally { 
                threadPool.shutdown();
            }
        }
    }

输出：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dvb19ob21l_size_16_color_FFFFFF_t_70 3]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dvb19ob21l_size_16_color_FFFFFF_t_70]: /images/20230529/411ebbead3734f4fba6ed5a4a8f4c043.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dvb19ob21l_size_16_color_FFFFFF_t_70 1]: /images/20230529/9ad4d4712a6b45f492c09f93013e947d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dvb19ob21l_size_16_color_FFFFFF_t_70 2]: /images/20230529/ef6b7dc316a14c6eab47286d43953dcd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1dvb19ob21l_size_16_color_FFFFFF_t_70 3]: /images/20230529/57b1e63a2a1340059a2d2c9af5ae5af2.png