线程池浅析

Posted 2021-04-06 java资料与技术共享平台

tags:

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

线程池浅析

导语

线程的创建、启动、销毁等是一个非常消耗资源的过程。引出线程池。

线程池作用

降低资源消耗，重复利用已创建好的线程。
提高响应速度，通过已经创建好的线程直接执行到达的任务，无需等待。
线程的统一管理，对线程统一分配、监控和调优（专人专职）。

线程池的创建

线程池的四种创建方式，本质都是通过改变构造函数的参数来创建不同的线程的。最终调用的构造函数都是：

    public ThreadPoolExecutor(int corePoolSize,                              int maximumPoolSize,                              long keepAliveTime,                              TimeUnit unit,                              BlockingQueue<Runnable> workQueue,                              ThreadFactory threadFactory,                              RejectedExecutionHandler handler) {        if (corePoolSize < 0 ||
            maximumPoolSize <= 0 ||
            maximumPoolSize < corePoolSize ||
            keepAliveTime < 0)            throw new IllegalArgumentException();        if (workQueue == null || threadFactory == null || handler == null)            throw new NullPointerException();        this.corePoolSize = corePoolSize;        this.maximumPoolSize = maximumPoolSize;        this.workQueue = workQueue;        this.keepAliveTime = unit.toNanos(keepAliveTime);        this.threadFactory = threadFactory;        this.handler = handler;
    }

以下以demo分别说明线程池的创建：

一、创建缓存线程

        ExecutorService threadPool = Executors.newCachedThreadPool();        for(int i=0;i<10;i++){            int temp = i;
            threadPool.execute(new Runnable() {                @Override
                public void run() {
                    System.out.println(Thread.currentThread().getName()+","+temp);
                }
            });
        }
        threadPool.shutdown();// 停掉线程池

二、创建固定长度的线程(常用)

        ExecutorService threadPool = Executors.newFixedThreadPool(3);        for (int i = 0; i < 10; i++) {            int temp = i;
            threadPool.execute(new Runnable() {                @Override
                public void run() {
                    System.out.println(Thread.currentThread().getName()+","+temp);
                }
            });
        }
        threadPool.shutdown();// 停掉线程池

三、创建定时线程

        ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(3);
        threadPool.schedule(new Runnable() {            @Override
            public void run() {
                System.out.println("我是定时线程，三秒后启动");
            }
        },3, TimeUnit.SECONDS); // 第一个参数是任务，第二个参数是时间长度，第三个参数时间单位
        threadPool.shutdown();// 停掉线程池

四、创建单线程

        ExecutorService threadPool = Executors.newSingleThreadExecutor();        for (int i = 0; i < 10; i++) {
            threadPool.execute(new Runnable() {                @Override
                public void run() {
                    System.out.println("我是单线程线程");
                }
            });
        }
        threadPool.shutdown();// 停掉线程池

线程池参数说明

重点：几乎是面试必问的。

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

corePoolSize：核心线程数

maximumPoolSize：最大线程数

keepAliveTimea：线程空闲时间

unit：TimeUnit枚举类型的值，代表keepAliveTime时间单位，可以取下列值：