并发工具包-Concurrent
JDK1.5以后为我们专门提供了一个并发工具包java.util.concurrent。
java.util.concurrent 包含许多线程安全、测试良好、高性能的并发构建块。创建 concurrent 的目的就是要实现 Collection 框架对数据结构所执行的并发操作。通过提供一组可靠的、高性能并发构建块，开发人员可以提高并发类的线程安全、可伸缩性、性能、可读性和可靠性，
并发是伴随着多核处理器的诞生而产生的，为了充分利用硬件资源，诞生了多线程技术。但是多线程又存在资源竞争的问题，引发了同步和互斥的问题，JDK1.5推出的java.util.concurrent(并发工具包）来解决这些问题。
new Thread的弊端
new Thread()新建对象，性能差
线程缺乏统一管理，可能无限制的新建线程，相互竞争，严重时会占用过多系统资源导致死机或OOM
ThreadPool - 线程池
重用存在的线程，减少对象对象、消亡的开销
线程总数可控，提高资源的利用率
避免过多资源竞争，避免阻塞
提供额外功能，定时执行、定期执行、监控等。
线程池的种类
在java.util.concurrent中，提供了工具类Executors（调
度器）对象来创建线程池，可创建的线程池有四种：
- CachedThreadPool - 可缓存线程池
- FixedThreadPool - 定长线程池
- SingleThreadExecutor - 单线程池
- ScheduledThreadPool - 调度线程池
CachedThreadPool
package com.caiweiwei.lianxi.controller; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class ThreadPoolSample1 { public static void main(String[] args) { ExecutorService threadPool= Executors.newCachedThreadPool();//创建一个可缓存线程池 //可缓存线程池的特点是，无限大，如果线程池中没有可用的线程则创建，有空闲线程则利用起来 for (int i=0;i<=100;i++){ int index=i; threadPool.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName()+":"+index); } }); } try{ Thread.sleep(1000);//主线程足够的运行时间 }catch (Exception e){ e.printStackTrace(); } //shutdown() 代表关闭线程池（等待所有线程完成） //shutdownNow() 代表立即终止线程池的运行，不等待线程,不推荐使用 threadPool.shutdown(); } }
FixedThreadPool
package com.caiweiwei.lianxi.controller; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class ThreadPoolSample2 { public static void main(String[] args) { //ExecutorService用于管理线程池 ExecutorService executorService = Executors.newFixedThreadPool(3); //创建一个可创建一个定长线程池 //定长线程池的特点是固定线程总数，空间线程用于执行任务，如果线程都在使用后续任务则处于等待状态，在线程池中的线程 //如果任务处于等待的状态，备选的等待算法默认为FIFO（先进先出) LIFO(后进先出) //执行任务后再执行后续的任务。 for (int i = 0; i < 1000; i++) { int index = i; executorService.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName()+":"+index); } }); } try { Thread.sleep(1000); }catch (Exception e){ e.printStackTrace(); } //shutdown() 代表关闭线程池（等待所有线程完成） //shutdownNow() 代表立即终止线程池的运行，不等待线程,不推荐使用 executorService.shutdown(); } }
SingleThreadExecutor
package com.caiweiwei.lianxi.controller; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class ThreadPoolSample3 { public static void main(String[] args) { ExecutorService threadPool = Executors.newSingleThreadExecutor();//单线程线程池 for (int i = 0; i < 1000; i++) { int index = i; threadPool.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + ":" + index); } }); } try{ Thread.sleep(1000); }catch (Exception e){ e.printStackTrace(); } //shutdown() 代表关闭线程池（等待所有线程完成） //shutdownNow() 代表立即终止线程池的运行，不等待线程,不推荐使用 threadPool.shutdown(); } }
ScheduledThreadPool
package com.caiweiwei.lianxi.controller; import java.util.Date; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; public class ThreadPoolSample4 { public static void main(String[] args) { ScheduledExecutorService scheduledExecutorService= Executors.newScheduledThreadPool(5);//可调度线程池 /*//延迟三秒执行一次Run方法 scheduledThreadPool.schedule(new Runnable() { @Override public void run() { System.out.println("延迟3秒执行"); } } , 3 , TimeUnit.SECONDS);*/ //Timer , 项目实际开发中scheduledThreadPool与Timer都不会用到，应为有成熟的调度框架Quartz，或者Spring自带调度， //程序的调度框架支持一种表达式叫做Cron表达式，有兴趣的童鞋可以了解一下。 scheduledExecutorService.scheduleAtFixedRate(new Runnable() { @Override public void run() { System.out.println(new Date() + "延迟1秒执行，每三秒执行一次"); } }, 1, 3, TimeUnit.SECONDS); } }
