Java 线程池的四种用法与使用场景

╰+攻爆jí腚メ 2021-08-01 00:41 443阅读 0赞

### **一、如下方式存在的问题** ###

new Thread() {
        @Override
        public void run() {
            // 业务逻辑
        }
    }.start();

1、首先频繁的创建、销毁对象是一个很消耗性能的事情；

2、如果用户量比较大，导致占用过多的资源，可能会导致我们的服务由于资源不足而宕机；

3、综上所述，在实际的开发中，这种操作其实是不可取的一种方式。

### **二、使用线程池有什么优点** ###

1、线程池中线程的使用率提升，减少对象的创建、销毁；

2、线程池可以控制线程数，有效的提升服务器的使用资源，避免由于资源不足而发生宕机等问题；

### **三、线程池的四种使用方式** ###

#### 1、newCachedThreadPool ####

创建一个线程池，如果线程池中的线程数量过大，它可以有效的回收多余的线程，如果线程数不足，那么它可以创建新的线程。

public static void method() throws Exception {
    
        ExecutorService executor = Executors.newCachedThreadPool();
    
        for (int i = 0; i < 5; i++) {
    
            final int index = i;
    
            Thread.sleep(1000);
    
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println(Thread.currentThread().getName() + "  " + index);
                }
            });
        }
    }

执行结果

![640?wx\_fmt=png][640_wx_fmt_png]

通过分析我看可以看到，至始至终都由一个线程执行，实现了线程的复用，并没有创建多余的线程。

如果当我们的业务需要一定的时间进行处理，那么将会出现什么结果。 我们来模拟一下。

![640?wx\_fmt=gif][640_wx_fmt_gif]

可以明显的看出，现在就需要几条线程来交替执行。

**不足**：这种方式虽然可以根据业务场景自动的扩展线程数来处理我们的业务，但是最多需要多少个线程同时处理缺是我们无法控制的；

**优点**：如果当第二个任务开始，第一个任务已经执行结束，那么第二个任务会复用第一个任务创建的线程，并不会重新创建新的线程，提高了线程的复用率；

#### 2、newFixedThreadPool ####

这种方式可以指定线程池中的线程数。举个栗子，如果一间澡堂子最大只能容纳20个人同时洗澡，那么后面来的人只能在外面排队等待。如果硬往里冲，那么只会出现一种情景，摩擦摩擦...

首先测试一下最大容量为一个线程，那么会不会是我们预测的结果。

public static void method_01() throws InterruptedException {
    
        ExecutorService executor = Executors.newFixedThreadPool(1);
    
        for (int i = 0; i < 10; i++) {
    
            Thread.sleep(1000);
            final int index = i;
    
            executor.execute(() -> {
                try {
                    Thread.sleep(2 * 1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName() + "  " + index);
            });
        }
        executor.shutdown();
    }

执行结果

![640?wx\_fmt=gif][640_wx_fmt_gif 1]

我们改为3条线程再来看下结果

![640?wx\_fmt=gif][640_wx_fmt_gif 2]

**优点**：两个结果综合说明，newFixedThreadPool的线程数是可以进行控制的，因此我们可以通过控制最大线程来使我们的服务器打到最大的使用率，同事又可以保证及时流量突然增大也不会占用服务器过多的资源。

#### 3、newScheduledThreadPool ####

该线程池支持定时，以及周期性的任务执行，我们可以延迟任务的执行时间，也可以设置一个周期性的时间让任务重复执行。 该线程池中有以下两种延迟的方法。

*  scheduleAtFixedRate

测试一

public static void method_02() {
        ScheduledExecutorService executor = Executors.newScheduledThreadPool(5);
    
        executor.scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
                long start = new Date().getTime();
                System.out.println("scheduleAtFixedRate 开始执行时间:" +
                        DateFormat.getTimeInstance().format(new Date()));
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                long end = new Date().getTime();
                System.out.println("scheduleAtFixedRate 执行花费时间=" + (end - start) / 1000 + "m");
                System.out.println("scheduleAtFixedRate 执行完成时间：" + DateFormat.getTimeInstance().format(new Date()));
                System.out.println("======================================");
            }
        }, 1, 5, TimeUnit.SECONDS);
    }

执行结果

![640?wx\_fmt=gif][640_wx_fmt_gif 3]

测试二

![640?wx\_fmt=gif][640_wx_fmt_gif 4]

总结：以上两种方式不同的地方是任务的执行时间，如果间隔时间大于任务的执行时间，任务不受执行时间的影响。如果间隔时间小于任务的执行时间，那么任务执行结束之后，会立马执行，至此间隔时间就会被打乱。

*  scheduleWithFixedDelay

测试一

public static void method_03() {
        ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);
    
        executor.scheduleWithFixedDelay(new Runnable() {
            @Override
            public void run() {
                long start = new Date().getTime();
                System.out.println("scheduleWithFixedDelay 开始执行时间:" +
                        DateFormat.getTimeInstance().format(new Date()));
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                long end = new Date().getTime();
                System.out.println("scheduleWithFixedDelay执行花费时间=" + (end - start) / 1000 + "m");
                System.out.println("scheduleWithFixedDelay执行完成时间："
                        + DateFormat.getTimeInstance().format(new Date()));
                System.out.println("======================================");
            }
        }, 1, 2, TimeUnit.SECONDS);
    }

执行结果

![640?wx\_fmt=gif][640_wx_fmt_gif 5]

测试二

public static void method_03() {
        ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);
    
        executor.scheduleWithFixedDelay(new Runnable() {
            @Override
            public void run() {
                long start = new Date().getTime();
                System.out.println("scheduleWithFixedDelay 开始执行时间:" +
                        DateFormat.getTimeInstance().format(new Date()));
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                long end = new Date().getTime();
                System.out.println("scheduleWithFixedDelay执行花费时间=" + (end - start) / 1000 + "m");
                System.out.println("scheduleWithFixedDelay执行完成时间："
                        + DateFormat.getTimeInstance().format(new Date()));
                System.out.println("======================================");
            }
        }, 1, 2, TimeUnit.SECONDS);
    }

执行结果

![640?wx\_fmt=gif][640_wx_fmt_gif 6]

**总结**：同样的，跟scheduleWithFixedDelay测试方法一样，可以测出scheduleWithFixedDelay的间隔时间不会受任务执行时间长短的影响。

#### 4、newSingleThreadExecutor ####

这是一个单线程池，至始至终都由一个线程来执行。

public static void method_04() {
    
        ExecutorService executor = Executors.newSingleThreadExecutor();
    
        for (int i = 0; i < 5; i++) {
            final int index = i;
            executor.execute(() -> {
                try {
                    Thread.sleep(2 * 1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName() + "   " + index);
            });
        }
        executor.shutdown();
    }

执行结果

![640?wx\_fmt=gif][640_wx_fmt_gif 7]

### **四、线程池的作用** ###

**线程池的作用主要是为了提升系统的性能以及使用率**。文章刚开始就提到，如果我们使用最简单的方式创建线程，如果用户量比较大，那么就会产生很多创建和销毁线程的动作，这会导致服务器在创建和销毁线程上消耗的性能可能要比处理实际业务花费的时间和性能更多。线程池就是为了解决这种这种问题而出现的。

同样思想的设计还有很多，比如**数据库连接池**，由于频繁的连接数据库，然而创建连接是一个很消耗性能的事情，所有数据库连接池就出现了。

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

\-END-

如果看到这里，说明你喜欢这篇文章，请 **转发** **、点赞**。微信搜索「web\_resource」，关注后回复「进群」或者扫描下方二维码即可进入无广告交流群。

**↓扫描二维码进群↓**

![640?wx\_fmt=png][640_wx_fmt_png 1]

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

**推** **荐** **阅** **读 **

***2.***

***4. ***

***5.***

[640_wx_fmt_png]: /images/20210731/39f046aa4036457c90b69a5b3945adb3.png?wx_fmt=png
[640_wx_fmt_gif]: /images/20210731/c818b33e90ab4cdb9f34eee8c148e588.png?wx_fmt=gif
[640_wx_fmt_gif 1]: /images/20210731/303b23e0b06b447c8d0636c5da3bfab3.png?wx_fmt=gif
[640_wx_fmt_gif 2]: /images/20210731/a3905f9554da40898423fde50f1483ce.png?wx_fmt=gif
[640_wx_fmt_gif 3]: /images/20210731/a53ebbe94c8e4afcb02a5d906584c81c.png?wx_fmt=gif
[640_wx_fmt_gif 4]: /images/20210731/b0836d99fd7346e590cd35bd22847b6c.png?wx_fmt=gif
[640_wx_fmt_gif 5]: /images/20210731/5e0579afe4fd48aeb41179656ecc6ab8.png?wx_fmt=gif
[640_wx_fmt_gif 6]: /images/20210731/e7feea6dc16b4aa0afd3b2ccd688d085.png?wx_fmt=gif
[640_wx_fmt_gif 7]: /images/20210731/e665a586eef2409791e3b662c563cf7b.png?wx_fmt=gif
[640_wx_fmt_png 1]: /images/20210731/8af1fe5355fa41ecbe970403921465e1.png?wx_fmt=png