线程池可以控制运行的线程数量，本文就线程池做了详细的介绍，需要了解的小伙伴可以参考一下
ThreadPool
线程池的优势
线程池做的工作主要是控制运行的线程数量，处理过程中将任务放入队列，然后在线程创建后启动这些任务，如果线程数量超过了最大数量，超出的线程排队等候，等待其他线程执行完毕，再从队列中取出任务来执行
线程池的特点
线程复用、控制最大并发数、管理线程
- 降低资源消耗。重复利用已创建的线程，降低创建和销毁线程的开销
- 提高响应速度。当任务到达时，任务可以不需要等待线程创建就能立刻执行
- 提高线程的可管理性。使用线程池可以对线程进行统一的分配、调优和监控
1 线程池的方法
执行长期任务性能好，创建一个线程池，一池有N个固定的线程，可以控制线程最大并发数，有固定线程数的线程池[
ExecutorService threadPool = Executors.newFixedThreadPool(N);
单个任务执行，它只会使用单个工作线程，一池一线程
ExecutorService threadPool = Executors.newSingleThreadExecutor();
执行短期异步任务，可缓存线程池，线程池根据需要创建新线程，但在先前构造的线程可以复用，也可灵活回收空闲的线程，可扩容的池
ExecutorService threadPool = Executors.newCachedThreadPool();
周期性线程池；支持定时及周期性任务执行
ExecutorService threadPool = Executors.newScheduledThreadPool();
(1) newFixedThreadPool
可以控制线程最大并发数的线程池：
public class FixedThreadPool { private static AtomicInteger num = new AtomicInteger(0); private static ExecutorService executorService = Executors.newFixedThreadPool(2); public static void main(String[] args) { countSum c= new countSum(); //将coutSum作为Task，submit至线程池 for (int i = 0; i <2; i++) { executorService.submit(c); } //Task执行完成后关闭 executorService.shutdown(); } static class countSum implements Runnable{ @Override public void run() { for (int i = 0; i <500; i++) { try{ System.out.println("Thread - "+Thread.currentThread().getName()+" count= "+ num.getAndIncrement()); Thread.sleep(100); }catch (Exception e){ e.printStackTrace(); } } } } }结果：
(2) newSingleThreadExecutor
只会使用唯一的工作线程执行任务的线程池：
public class SingleThreadExecutor { private static AtomicInteger num = new AtomicInteger(0); private static ExecutorService executorService = Executors.newSingleThreadExecutor(); public static void main(String[] args) { //将coutSum作为Task，submit至线程池 for (int i = 0; i <2; i++) { executorService.submit(new countSum()); } //Task执行完成后关闭 executorService.shutdown(); } static class countSum implements Runnable{ @Override public void run() { for (int i = 0; i <500; i++) { try{ System.out.println("Thread - "+Thread.currentThread().getName()+" count= "+ num.getAndIncrement()); Thread.sleep(100); }catch (Exception e){ e.printStackTrace(); } } } } }结果：
(3) newScheduledThreadPool
传参值为corePoolSize大小，支持定时及周期性任务执行
延期执行示例：调用schedule方法，三个参数：Task，Delay，TimeUnit
public class ScheduledThreadPool { // corePoolSize = 2 private static ScheduledExecutorService service = Executors.newScheduledThreadPool(2); public static void main(String[] args) { System.out.println("Thread - "+Thread.currentThread().getName()+" BEGIN "+ new Date()); service.schedule(new print(),5, TimeUnit.SECONDS); service.shutdown(); } static class print implements Runnable{ @Override public void run() { for (int i = 0; i <10; i++) { try{ System.out.println("Thread - "+Thread.currentThread().getName()+" Delay 5 second and sleep 2 second "+ new Date()); Thread.sleep(2000); }catch (Exception e){ e.printStackTrace(); } } } } }结果：
