JUC--自定义线程池

Posted yanxiaolong

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了JUC--自定义线程池相关的知识,希望对你有一定的参考价值。

自定义线程线程池

如果当前线程池中的线程数目小于corePoolSize,则每来一个任务,就会创建一个线程去执行这个任务;如果当前线程池中的线程数目>=corePoolSize,则每来一个任务,会尝试将其添加到任务缓存队列当中,若添加成功,则该任务会等待空闲线程将其取出去执行;若添加失败(一般来说是任务缓存队列已满),则会尝试创建新的线程去执行这个任务;如果队列已经满了,则在总线程数不大于maximumPoolSize的前提下,则创建新的线程 如果当前线程池中的线程数目达到maximumPoolSize,则会采取任务拒绝策略进行处理;如果线程池中的线程数量大于 corePoolSize时,如果某线程空闲时间超过keepAliveTime,线程将被终止,直至线程池中的线程数目不大于corePoolSize;如果允许为核心池中的线程设置存活时间,那么核心池中的线程空闲时间超过keepAliveTime,线程也会被终止。

这是上篇文章讲到的 线程池原理 https://blog.csdn.net/qq_41977838/article/details/105918233

下面我们利用原理自定义一个线程池

 
   
   
 
  1. public class Test0007 {


  2. public static void main(String[] args) {

  3. ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 2, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(3));

  4. for (int i = 1; i <= 6; i++) {

  5. TaskThred t1 = new TaskThred("任务" + i);

  6. executor.execute(t1);

  7. }

  8. executor.shutdown();

  9. }

  10. }


  11. class TaskThred implements Runnable {

  12. private String taskName;


  13. public TaskThred(String taskName) {

  14. this.taskName = taskName;

  15. }


  16. @Override

  17. public void run() {

  18. System.out.println(Thread.currentThread().getName()+taskName);

  19. }


  20. }

通过线程池原理我们就可以实现一个简单的自定义线程池

  1. 我们直接实现 new ThreadPoolExecutor(1, 2, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(3)); (详解:ThreadPoolExecutor 底层实现线程池方法,1:核心线程数,2:最大线程数,60L :线程没有任务执行时最多保持多久时间会终止,TimeUnit.SECONDS:底层实现,表示一秒为单位,new ArrayBlockingQueue<>(3) :ArrayBlockingQueue是一个阻塞式的队列,传入队列个数 )

  2. 调用 executor.execute(t1);

  3. 结束 executor.shutdown();


以上是关于JUC--自定义线程池的主要内容,如果未能解决你的问题,请参考以下文章

newCacheThreadPool()newFixedThreadPool()newScheduledThreadPool()newSingleThreadExecutor()自定义线程池(代码片段

JUC学习之共享模型之工具上之线程池浅学

JUC - 共享模型之工具 - 第六篇

Java多线程系列--“JUC线程池”04之 线程池原理

JUC系列线程池基础使用

Java多线程系列--“JUC线程池”03之 线程池原理