Java线程池详解

小鱼儿 2023-10-18 21:41 1阅读 0赞

**目录**

一、线程池的概念和原理

1、概述

2、线程池的概念

线程池：

3、线程池的底层原理

4、合理利用线程池能带来的好处：

二、线程池的代码实现

1、Executors线程池的工厂类（用来生产线程池）

生产线程池的静态方法：

2、ExecutorService线程池接口

用来从线程池中获取线程，调用start方法执行线程任务：

关闭/销毁线程池的方法：

3、线程池的使用步骤

4、代码演示

主方法：

Runnable接口实现类：

运行结果：

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

# 一、线程池的概念和原理 #

## 1、概述 ##

如果并发的线程数量很多，而每个线程做的却是很简单的问题，这就大大降低了系统的效率；

那么是否有一个方法可以使线程得到复用，就是执行完一个任务，并不被销毁，而是可以继续执行其他任务？

在java中可以通过线程池达到这个效果；

## 2、线程池的概念 ##

### 线程池： ###

就是一个可以容纳多个线程的容器，其中的线程可以反复使用，省去了反复的创建线程的操作，无需反复创建线程而消耗过多资源；

## 3、线程池的底层原理 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz_size_16_color_FFFFFF_t_70][]

## 4、合理利用线程池能带来的好处： ##

①降低资源消耗；

②提高响应速度；

③提高线程的可管理性；

# 二、线程池的代码实现 #

## 1、Executors线程池的工厂类（用来生产线程池） ##

### 生产线程池的静态方法： ###

static ExecutorService newFixedThreadPool(int nThreads)创建一个可重用固定线程数的线程池，以共享的无界队列方式来运行这些线程。

**参数：**创建线程池所包含线程的数量；

**返回值：**返回的是ExecutorService接口的实现类对象，我们可以用ExecutorService接口接收（面向接口编程）；

## 2、ExecutorService线程池接口 ##

### 用来从线程池中获取线程，调用start方法执行线程任务： ###

submit(Runnable task)提交一个Runnable任务用于执行；

### 关闭/销毁线程池的方法： ###

void shutdown()

## 3、线程池的使用步骤 ##

①使用线程工厂Executors的静态方法newFixedThreadPool生成一个指定线程数量的线程池，使用ExecutorService接口接收；

②创建一个类，实现Runnable接口，重写run方法，设置线程任务；

③调用ExecutorService中的submit方法，传递线程任务（实现类），开启线程，执行run方法；

④调用ExecutorService中的shutdown方法，销毁线程池，**不建议使用（因为线程池的作用就是复用线程）**；

## 4、代码演示 ##

### 主方法： ###

package study.thread;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class MyExecutors {
        public static void main(String[] args) {
            //①使用线程工厂Executors的静态方法newFixedThreadPool生成一个指定线程数量的线程池；
            ExecutorService executorService = Executors.newFixedThreadPool(2);
            //②创建一个类，实现Runnable接口，重写run方法，设置线程任务；
            //③调用ExecutorService中的submit方法，传递线程任务（实现类），开启线程，执行run方法；
            executorService.submit(new MyRunnableImpl());
            //一个线程使用完毕之后，会自动归还
            executorService.submit(new MyRunnableImpl());
            executorService.submit(new MyRunnableImpl());
            //可以销毁线程池（不建议执行,若不写这个程序不会停止，尴尬，用时需深入研究）
            executorService.shutdown();
    
        }
    }

### Runnable接口实现类： ###

package study.thread;
    
    public class MyRunnableImpl implements Runnable {
        //②创建一个类，实现Runnable接口，重写run方法，设置线程任务；
        @Override
        public void run() {
            System.out.println(Thread.currentThread().getName()+"啦啦啦啦啦啦啦啦啦");
        }
    }

### 运行结果： ###

pool-1-thread-2啦啦啦啦啦啦啦啦啦
    pool-1-thread-1啦啦啦啦啦啦啦啦啦
    pool-1-thread-2啦啦啦啦啦啦啦啦啦

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20190715143157397.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz,size_16,color_FFFFFF,t_70