多线程15/使用线程池

缺乏、安全感 2023-10-04 16:41 62阅读 0赞

### 使用线程池 ###

**背景**：经常创建和销毁、使用量特别大的资源，比如并发情况下的线程，对性能影响很大。

**思路**：提前创建好多个线程，放入线程池中，使用时直接获取，使用完放回池中。可以避免频繁创建销毁、实现重复利用。类似生活中的公共交通工具。

**好处**：

1.  提高响应速度（减少了创建新线程的时间)
2.  降低资源消耗（重复利用线程池中线程，不需要每次都创建)
3.  便于线程管理  
    corePoolSize: 核心池的大小  
    maximumPoolSize: 最大线程数  
    keepAliveTime: 线程没有任务时最多保持多长时间后会终止

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

##### 线程池相关API #####

> JDK5.0起提供了线程池相关API:ExecutorService和 Executors

> ExecutorService:真正的线程池接口。常见子类ThreadPoolExecutor

1.  void execute(Runnable command):执行任务/命令，没有返回值，一般用来执行  
    Runnable
2.  < T > Future< T > submit(Callable task):执行任务，有返回值，一般又来执行Callable
3.  void shutdown():关闭连接池

> Executors：工具类、线程池的工厂类，用于创建并返回不同类型的线程池

1.  **Executors.newCachedThreadPool()**： 创建一个可根据需要创建新线程的线程池
2.  **Executors.newFixedThreadPool(n)**： 创建一个可重用固定线程数的线程池
3.  **Executors.newSingleThreadExecutor()**： 创建一个只有一个线程的线程池
4.  **Executors.newScheduledThreadPool(n)**： 创建一个线程池，它可安排在给定延迟后运行命令或者定期地执行。

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

> 例子：利用线程池，分线程输出奇偶遍历  
> 1.提供指定线程数量的线程池  
> 2.执行指定的线程的操作。需要提供实现Runnable接口或Callable接口实现类的对象  
> 3.关闭线程池

package com.dxc;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    //偶数线程
    class NumberThread implements  Runnable{
        
    
        @Override
        public void run() {
        
            for (int i = 0; i <= 100; i++) {
        
                if (i % 2 == 0){
        
                    System.out.println(Thread.currentThread().getName()+":"+i);
                }
            }
        }
    }
    //奇数线程
    class NumberThread1 implements  Runnable{
        
    
        @Override
        public void run() {
        
            for (int i = 0; i <= 100; i++) {
        
                if (i % 2 != 0){
        
                    System.out.println(Thread.currentThread().getName()+":"+i);
                }
            }
        }
    }
    
    public class ThreadPool {
        
        public static void main(String[] args) {
        
            //1.提供指定线程数量的线程池
            ExecutorService service = Executors.newFixedThreadPool(10);
            //2.执行指定的线程的操作。需要提供实现Runnable接口或Callable接口实现类的对象
            service.execute(new NumberThread());//适合适用于Runnable
            service.execute(new NumberThread1());
    
            //service.submit(Callable callable);//适合使用于callable
    
            //3.关闭线程池
            service.shutdown();
        }
    }

> 结果：部分截图

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80ODA2MzY2MA_size_16_color_FFFFFF_t_70]

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

想更深入了解可以参考视频：[**使用线程池**][Link 1]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80ODA2MzY2MA_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/91ce0a7a169d48069901e8d6e38969dd.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80ODA2MzY2MA==,size_16,color_FFFFFF,t_70
[Link 1]: https://www.bilibili.com/video/BV1Kb411W75N?p=446&spm_id_from=pageDriver