JUC--自定义线程池

自定义线程线程池

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

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

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

1. public class Test0007 {

2. 
   

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

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

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

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

7.            executor.execute(t1);

8.        }

9.        executor.shutdown();

10.    }

11. }

12. 
    

13. class TaskThred implements Runnable {

14.    private String taskName;

15. 
    

16.    public TaskThred(String taskName) {

17.        this.taskName = taskName;

18.    }

19. 
    

20.    @Override

21.    public void run() {

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

23.    }

24. 
    

25. }

经过线程池原理咱们就能够实现一个简单的自定义线程池

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);

结束 executor.shutdown();