ThreadPool：线程池

　　1、定义

　　缓存一定线程数量的区域。

　　2、作用

　　复用、管理线程，避免新建线程/销毁线程消耗CPU资源。

　　3、核心参数

　　参数　　作用

　　corePoolSize(核心线程数)　　核心线程会一直存活

　　maximumPoolSize(最大线程数)　　活动线程达到最大线程数，后续新任务会阻塞

　　keepAliveTime(闲置线程超时时长)　　非核心线程闲置超过该时长将被回收(设置作用于核心线程threadPoolExecutor.allowCoreThreadTimeOut(true))

　　unit(keepAliveTime 单位)　　如：TimeUnit.MILLISECONDS, TimeUnit.SECONDS

　　workQueue(任务队列)　　存放 execute() 提交的 Runnable 对象

　　threadFactory(线程工厂)　　为线程池创建线程，Thread newThread(Runnable r)

　　4、工作流程

　　5、常用线程池

　　类型　　线程类型　　线程数量　　特点　　场景

　　定长线程池(FixedThreadPool)　　核心线程　　固定　　1、核心线程空闲不会回收。2、所有线程处于活动状态，新的任务将处于等待状态，直到有线程空闲。3、任务队列无大小限制。4、堆积的任务可能占用大内存　　控制线程最大并发数

　　定时线程池(ScheduledThreadPool)　　核心、非核心线程　　核心:固定，非核心:无限制　　1、非核心线程闲置时会被回收。2、非核心线程无限制可能创建非常多线程。　　执行定时/ 周期性任务

　　可缓存线程池(CachedThreadPool)　　非核心　　无限制　　1、优先使用闲置线程处理任务。2、线程大小无限制。3、60 秒 回收闲置线程。4、非核心线程无限制可能创建非常多线程。　　执行数量多、耗时少的任务

　　单线程线程池(SingleThreadExecutor)　　核心线程　　1个　　1、任务顺序执行。2、不需要处理线程同步。3、堆积的任务可能占用大内存　　单线程

　　6、具体使用

　　public class ExecutorDemo {

　　public static void main(String[] args) {

　　createThreadPoolExecutor();

　　createFixedThreadPool();

　　createScheduledThreadPool();

　　createCachedThreadPool();

　　createSingleThreadExecutor();

　　}

　　private static final int CPU_COUNT = Runtime.getRuntime().availableProcessors();

　　private static final int CORE_POOL_SIZE = Math.max(2, Math.min(CPU_COUNT - 1, 4));

　　private static final int MAXIMUM_POOL_SIZE = CPU_COUNT * 2 + 1;

　　private static final int KEEP_ALIVE_SECONDS = 30;

　　private static final BlockingQueue sPoolWorkQueue =

　　new LinkedBlockingQueue(128);

　　private static final ThreadFactory sThreadFactory = new ThreadFactory() {

　　private final AtomicInteger mCount = new AtomicInteger(1);

　　@Override

　　public Thread newThread(Runnable r) {

　　return new Thread(r, "AsyncTask #" + mCount.getAndIncrement());

　　}

　　};

　　public static void createThreadPoolExecutor() {

　　// 1.创建自定义线程池

　　ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(

　　CORE_POOL_SIZE,

　　MAXIMUM_POOL_SIZE,

　　KEEP_ALIVE_SECONDS,

　　TimeUnit.SECONDS,

　　sPoolWorkQueue,

　　sThreadFactory);

　　threadPoolExecutor.allowCoreThreadTimeOut(true);

　　// 2.创建任务

　　Runnable task = new Runnable() {

　　@Override

　　public void run() {

　　System.out.println("自定义线程池-任务执行");

　　}

　　};

　　// 3.通过线程池执行任务

　　threadPoolExecutor.execute(task);

　　// 4.关闭线程池

　　threadPoolExecutor.shutdown();

　　}

　　public static void createFixedThreadPool() {

　　// 1.创建定长线程池

　　// public static ExecutorService newFixedThreadPool(int var0) {

　　// return new ThreadPoolExecutor(var0, var0, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue());

　　// }

　　ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);

　　// 2.创建任务

　　Runnable task = new Runnable() {

　　@Override

　　public void run() {

　　System.out.println("定长线程池-任务执行");

　　}

　　};

　　// 3.通过线程池执行任务

　　fixedThreadPool.execute(task);

　　// 4.关闭线程池

　　fixedThreadPool.shutdown();

　　}

　　public static void createScheduledThreadPool() {

　　// 1.创建定时线程池

　　// public ScheduledThreadPoolExecutor(int var1) {

　　// super(var1, 2147483647, 0L, TimeUnit.NANOSECONDS, new ScheduledThreadPoolExecutor.DelayedWorkQueue());

　　// }　无锡妇科医院排行 http://www.0510bhyy.com/

　　ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

　　// 2.创建任务

　　Runnable task = new Runnable() {

　　@Override

　　public void run() {

　　System.out.println("定时线程池-任务执行");

　　}

　　};

　　// 3.通过线程池执行任务,execute 立即执行，schedule 延迟1s执行,scheduleAtFixedRate 延迟1s执行之后每隔2秒执行

　　// scheduledThreadPool.execute(task);

　　scheduledThreadPool.schedule(task, 1000L, TimeUnit.MILLISECONDS);

　　// scheduledThreadPool.scheduleAtFixedRate(task,1000L,2000L, TimeUnit.MILLISECONDS);

　　// 4.关闭线程池

　　scheduledThreadPool.shutdown();

　　}

　　public static void createCachedThreadPool() {

　　// 1.创建可缓存线程池

　　// public static ExecutorService newCachedThreadPool() {

　　// return new ThreadPoolExecutor(0, 2147483647, 60L, TimeUnit.SECONDS, new SynchronousQueue());

　　// }

　　ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

　　// 2.创建任务

　　Runnable task = new Runnable() {

　　@Override

　　public void run() {

　　System.out.println("可缓存线程池-任务执行");

　　}

　　};

　　// 3.通过线程池执行任务

　　cachedThreadPool.execute(task);

　　// 4.关闭线程池

　　cachedThreadPool.shutdown();

　　}

　　public static void createSingleThreadExecutor() {

　　// 1.创建单线程线程池

　　// public static ExecutorService newSingleThreadExecutor() {

　　// return new Executors.FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue()));

　　// }

　　ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

　　// 2.创建任务

　　Runnable task = new Runnable() {

　　@Override

　　public void run() {

　　System.out.println("单线程线程池-任务执行");

　　}

　　};

　　// 3.通过线程池执行任务

　　singleThreadExecutor.execute(task);

　　// 4.关闭线程池

　　singleThreadExecutor.shutdown();

　　}

　　}