非常适合新手学生的Java线程池超详细分析

更新时间：2022年03月21日 11:44:08 作者：摸鱼打酱油

作者是一个来自河源的大三在校生，以下笔记都是作者自学之路的一些浅薄经验，如有错误请指正，将来会不断的完善笔记，帮助更多的Java爱好者入门

线程池的好处

可以实现线程的复用，避免重新创建线程和销毁线程。创建线程和销毁线程对CPU的开销是很大的。
可以限制最大可创建的线程数，可根据自己的机器性能动态调整线程池参数，提高应用性能。
提供定时执行、并发数控制等功能。
统一管理线程。

创建线程池的五种方式

1：缓存线程池（不推荐）

2：固定容量线程池（不推荐）

3：单个线程池（不推荐）

4：定时任务线程池（不推荐）

5：通过ThreadPoolExecutor构造方法创建线程池（阿里巴巴开发手册十分推荐）

前面4种创建线程池的方式都是通过Executors的静态方法来创建。

缓存线程池CachedThreadPool

	ExecutorService executorService = Executors.newCachedThreadPool();

        for (int i = 0; i < 10; i++) {
            final int finalI = i;
            executorService.execute(new Runnable() {
                public void run() {
                    System.out.println(Thread.currentThread().getName()+"<thread->run>"+ finalI);
                }
            });
        }

为什么不推荐使用缓存线程池？

源码分析

public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, 2147483647, 60L, TimeUnit.SECONDS, new SynchronousQueue());
    }

 public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
        this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, Executors.defaultThreadFactory(), defaultHandler);
    }

通过上面两个代码片段，我们可以看出CachedThreadPool的maximumPoolSize为Integer的最大值2147483647，相当于可以无限的创建线程，而创建线程是需要内存的，这样就会造成内存溢出，而且一般的机器也没用那么大的内存给它创建这么大量的线程。

固定容量线程池FixedThreadPool

newFixedThreadPool(int num)，num就是我们要指定的固定线程数量

	ExecutorService executorService = Executors.newFixedThreadPool(5);

      for (int i = 0; i < 10; i++) {
          final int finalI = i;
          executorService.execute(new Runnable() {
              public void run() {
                  System.out.println(Thread.currentThread().getName()+"<thread->run>"+ finalI);
              }
          });
      }

输出：

pool-1-thread-5<thread->run>4
pool-1-thread-4<thread->run>3
pool-1-thread-5<thread->run>5
pool-1-thread-3<thread->run>2
pool-1-thread-3<thread->run>8
pool-1-thread-3<thread->run>9
pool-1-thread-2<thread->run>1
pool-1-thread-1<thread->run>0
pool-1-thread-5<thread->run>7
pool-1-thread-4<thread->run>6

可以看出起到了线程的复用。

为什么FixedThreadPool是固定线程池？

源码分析

public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue());
    }

通过这个源码可以看出，核心线程数（corePoolSize）和最大线程数（maximumPoolSize）都为nThreads，因为只有这样，线程池才不会进行扩容，线程数才固定。

单个线程池SingleThreadExecutor

	ExecutorService executorService = Executors.newSingleThreadExecutor();

      for (int i = 0; i < 10; i++) {
          final int finalI = i;
          executorService.execute(new Runnable() {
              public void run() {
                  System.out.println(Thread.currentThread().getName()+"<thread->run>"+ finalI);
              }
          });

      }

为什么SingleThreadExecutor只含有一个线程？

源码分析

public static ExecutorService newSingleThreadExecutor() {
        return new Executors.FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue()));
    }

通过这个源码可以看出，核心线程数（corePoolSize）和最大线程数（maximumPoolSize）都为1，所以它只含有一个线程。

定时任务线程池ScheduledThreadPool

	  int initDelay=10; //初始化延时
      int period=1;//初始化延迟过了之后，每秒的延时

      ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(10);

      scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
          @Override
          public void run() {
              System.out.println(Thread.currentThread().getName()+"<thread->run>");
          }
      },initDelay,period, TimeUnit.SECONDS);

这段代码的效果是：程序运行之后等10秒，然后输出第一次结果，之后每隔1秒输出一次结果。

为什么不推荐使用ScheduledThreadPool？

源码分析

public ScheduledThreadPoolExecutor(int corePoolSize) {
        super(corePoolSize, 2147483647, 10L, TimeUnit.MILLISECONDS, new ScheduledThreadPoolExecutor.DelayedWorkQueue());
    }

可以看出ScheduledThreadPool的最大线程数（maximumPoolSize）为Integer的最大值2147483647，相当于可以无限的创建线程，而创建线程是需要内存的，这样就会造成内存溢出，而且一般的机器也没用那么大的内存给它创建这么大量的线程。

ThreadPoolExecutor创建线程池（十分推荐）

	ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 20,
              2L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5),
              Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());

      for (int i = 0; i < 12; i++) {
          final int finalI = i;
          threadPoolExecutor.execute(new Runnable() {
              public void run() {
                  System.out.println(Thread.currentThread().getName()+"<thread->run>"+ finalI);
              }
          });
      }

ThreadPoolExecutor的七个参数详解

	public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) {
        
    }

corePoolSize：核心线程数。这些线程一旦被创建不会被销毁，是一直存在的。线程池默认是没有线程的，当有任务到来了，就会通过ThreadFactory去创建线程，并一直存在。
maximumPoolSize：最大线程数。非核心线程数=maximumPoolSize-corePoolSize，非核心线程数其实就是可扩容的线程数，可能会被销毁。
keepAliveTime：非核心线程的空闲存活时间。当通过扩容生成的非核心线程数在keepAliveTime这个时间后还处于空闲状态，则会销毁这些非核心线程。
unit：keepAliveTime的时间单位，例如：秒
workQueue：等待区。当来了>corePoolSize的任务时会把任务存放在workQueue这个阻塞队列中，等待其他线程处理。
threadFactory：线程工厂。创建线程的一种方式。
handler：拒绝策略。当来了>最大线程数+workQueue的容量则会执行拒绝策略

workQueue

ArrayBlockingQueue：有界阻塞队列。队列有大小限制，当容量超过时则会触发扩容或者拒绝策略。

	public ArrayBlockingQueue(int capacity) {
        this(capacity, false);
    }

LinkedBlockingQueue：无界阻塞队列，队列无大小限制，可能会造成内存溢出。

	 public LinkedBlockingQueue() {
        this(2147483647);
    }

handler

AbortPolicy：直接抛异常

	public static class AbortPolicy implements RejectedExecutionHandler {
        public AbortPolicy() {
        }

        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
            throw new RejectedExecutionException("Task " + r.toString() + " rejected from " + e.toString());
        }
    }

DiscardPolicy：不作任何操作。默默丢弃任务

	public static class DiscardPolicy implements RejectedExecutionHandler {
        public DiscardPolicy() {
        }

        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
        }
    }

DiscardOldestPolicy：丢掉存在时间最长的任务

	public static class DiscardOldestPolicy implements RejectedExecutionHandler {
        public DiscardOldestPolicy() {
        }

        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
            if (!e.isShutdown()) {
                e.getQueue().poll();
                e.execute(r);
            }

        }
    }

CallerRunsPolicy：让提交任务的线程去处理任务

	public static class CallerRunsPolicy implements RejectedExecutionHandler {
        public CallerRunsPolicy() {
        }

        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
            if (!e.isShutdown()) {
                r.run();
            }

        }
    }

threadFactory

	ThreadFactory threadFactory = Executors.defaultThreadFactory();

      threadFactory.newThread(new Runnable() {
          @Override
          public void run() {
              System.out.println("threadFactory");
          }
      }).start();

如何触发拒绝策略和线程池扩容？

	ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 20,
              2L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5),
              Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());

      for (int i = 0; i < 26; i++) { //并发数26
          final int finalI = i;
          threadPoolExecutor.execute(new Runnable() {
              public void run() {
                  System.out.println(Thread.currentThread().getName()+"<thread->run>"+ finalI);
              }
          });
      }
      /**
       * 核心线程数=10，最大线程数=20，故可扩容线程数=20-10
       * BlockingQueue的大小为5，故等待区的大小为5，也就是当并发数<=核心线程数+5不会扩容，并发数大于16才会扩容
       *
       * 触发扩容：并发数>核心线程数+阻塞队列的大小
       * 对于这段代码，如果来了26个并发，10个并发会被核心线程处理，5个会在等待区，剩下11个会因为等待区满了而触发扩容
       * 因为这里最多能够扩容10个，这里却是11个，所以会触发拒绝策略
       */

为什么这段代码会触发拒绝策略

对于这段代码，如果来了26个并发，10个并发会被核心线程处理，5个会在等待区，剩下11个会因为等待区满了而触发扩容，但是又因为因为这里最多能够扩容10个，这里却是11个，所以会触发拒绝策略。

怎么触发扩容

触发扩容：并发数>核心线程数（corePoolSize）+阻塞队列（workQueue）的大小

使用Java纯手写一个线程池

下期文章链接https://www.jb51.net/article/241589.htm

到此这篇关于非常适合新手学生的Java线程池超详细分析的文章就介绍到这了,更多相关Java 线程池内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Core Java 简单谈谈HashSet(推荐)
下面小编就为大家带来一篇Core Java 简单谈谈HashSet(推荐)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-09-09
java树形菜单对象生成
这篇文章主要为大家详细介绍了java树形菜单对象生成，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2021-05-05
Java对称加密算法DES实例详解
这篇文章主要介绍了Java对称加密算法DES,结合实例形式详细分析了java DES算法的概念、原理、实现方法与应用场景,需要的朋友可以参考下
2019-09-09
解决SpringMVC Controller 接收页面传递的中文参数出现乱码的问题
下面小编就为大家分享一篇解决SpringMVC Controller 接收页面传递的中文参数出现乱码的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2018-03-03
SpringBoot整合ES解析搜索返回字段问题
这篇文章主要介绍了SpringBoot整合ES解析搜索返回字段问题,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2023-03-03
spring boot输入数据校验(validation)的实现过程
web项目中，用户的输入总是被假定不安全不正确的，在被处理前需要做校验。本文介绍在spring boot项目中实现数据校验的过程，通过实例代码给大家介绍的非常详细，需要的朋友参考下吧
2021-09-09
Java中的FileInputStream是否需要close问题
这篇文章主要介绍了Java中的FileInputStream是否需要close问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-12-12
线程池调用kafka发送消息产生的内存泄漏问题排查解决
这篇文章主要为大家介绍了线程池调用kafka发送消息产生的内存泄漏问题排查解决,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
2023-08-08
Spring boot配置 swagger的示例代码
Swagger是一组开源项目，Spring 基于swagger规范，可以将基于SpringMVC和Spring Boot项目的项目代码，自动生成JSON格式的描述文件，接下来通过本文给大家介绍Spring boot配置 swagger的示例代码，一起看看吧
2021-09-09
详解springboot和vue前后端分离开发跨域登陆问题
这篇文章主要介绍了详解springboot和vue前后端分离开发跨域登陆问题，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-09-09