利用Executors创建不同的线程池满足不同场景的需求

      1. newFixedThreadPool(int nThreads)

          指定工作线程数量的线程池

      2. newCachedThreadPool()

         处理大量短时间工作任务的线程池,

           (1)试图缓存线程并重用，当无缓存线程可用时,就会创建新的工作线程;

           (2)如果线程闲置的时间超过阈值,则会被终止并移出缓存;

           (3)系统长时间闲置的时候,不会消耗什么资源

      3. newSingleThreadExecutor()

           创建唯一的工作者线程来执行任务,如果线程异常结束，会有另-个线程取代它

      4. newSingleThreadScheduledExecutor0与newScheduledThreadoo(int corePoolSize)

         定时或者周期性的工作调度,两者的区别在于单一工作线程还是多个线程

     5. newWorkStealingPool（）

         内部会构建ForkJoinPool ,利用working-stealing算法,并行地处理任务,不保证处理顺序

 

Fork/Join框架


Work- Stealing算法:某个线程从其他队列里窃取任务来执行
➢把大任务分割成若干个小任务并行执行,最终汇总每个小任务结果后
得到大任务结果的框架

J.U.C的三个Executor接口


➢Executor :运行新任务的简单接口,将任务提交和任务执行细节解耦
➢ExecutorService :具备管理执行器和任务生命周期的方法,提交任务机制更完善
➢ScheduledExecutorService :支持Future和定期执行任务

 

ThreadPoolExecutor的枸造函数

 

      > corePoolSize :核心线程程数量

      > maximumPoolSize :线程不移用时能移创建的最大线程数

      > workQueue :任务等待队列

      > keepAliveTime :拾占的顺序不一定,看运气

      > threadFactory 创建新线程程, Executors.defaultThreadFactory0
 

handler :线程池的饱和策略

 

➢AbortPolicy :直接抛出异常,这是默认策略

➢CallerRunsPolicy :用调用者所在的线程来执行任务

➢DiscardOldestPolicy :丢弃队列中靠最前的任务,并执行当前任务➢DiscardPolicy :直接丢弃任务

➢实现RejectedExecutionHandler接口的自定 义handler

 

Java线程池

1.新任务提交execute执行后的判断

      ●如果运行的线程少于corePoolSize ,则创建新线程来处理任务,即使线程池中的其他线程是空闲的;

      ●如果线程池中的线程数量大于等于 corePoolSize且小于 maximumPoolSize ,则只有当workQueue满时才创建新的线程去处          理任务;

      ●如果设置的corePoolSize 和maximumPoolSize相同,则创建的线程池的大小是固定的,这时如果有新任务提交,若workQueue          未满,则将请求放入workQueue中,等待有空闲的线程去从workQueue中取任务并处理;

      ●如果运行的线程数量大于等 于maximumPoolSize ,这时如果workQueue已经满了,则通过handler所指定的策略来处理任务;

 

2.线程池的状态
➢RUNNING :能接受新提交的任务,并且也能处理阻塞队列中的任务
➢SHUTDOWN :不再接受新提交的任务,但可以处理存量任务
➢STOP :不再接受新提交的任务,也不处理存量任务
➢TIDYING :所有的任务都已终止
➢TERMINATED : terminated()方法执行完后进入该状态

3.线程池的大小如何选定
> CPU密集型:线程数=按照核数或者核数+1没定
> I/O密集型:桟程数=CPU核数* (1 +平均等待吋向/平均工作时间)