自定义线程池

╰半橙微兮° 2021-09-30 02:30 357阅读 0赞

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

package 线程池;
    
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
    
    public class T2 {
    
        public static void main(String[] args) {
            ThreadPoolExecutor executor = new ThreadPoolExecutor(1,2,60L, TimeUnit.SECONDS,new ArrayBlockingQueue<>(3));
            for (int i = 1; i <= 6; i++) {
                TaskThred t1 = new TaskThred("任务" + i);
                executor.execute(t1);
            }
            executor.shutdown();
        }
    }
    
    class TaskThred implements Runnable{
        private String taskName;
    
        public TaskThred(String taskName) {
            this.taskName = taskName;
        }
        @Override
        public void run() {
            System.out.println(Thread.currentThread().getName()+taskName);
        }
    }