new Thread的弊端:
由此,java提供了四种线程池,它的目的在于
Executors是java线程池的顶层封装类,我们只需根据需要调用Executors中相应的方法即可。
newCachedThreadPool创建一个可缓存的线程池。
如果线程池大小超过处理任务需要的线程,那么就会回收部分空闲的线程;
当任务数增加时,此线程池又可以添加新线程来处理任务;
此线程池不会对线程池大小做限制,线程池最大值取决于jvm能够创建的大小。
newFixedThreadPool创建一个固定大小的线程池。
每提交一个任务就会新建一个线程,直到线程达到线程池的最大值;
线程池的大小一旦达到最大值就不会变,每个线程的存活时间是无限的,如果某个线程因为执行异常而结束,线程池会再补充一个;
如果线程池中的所有线程都处于繁忙状态,新任务申请线程时会进入堵塞队列。
newSingleThreadExector创建一个只有一个线程的线程池。
线程存活时间是无限的;
当该线程繁忙时,新任务申请线程会进入堵塞队列中。
newScheduledThreadPool创建一个固定大小的线程池。
线程池内线程存活时间无限制。
它主要用来在给定的延迟之后运行任务,或者定期执行任务。
例如定时轮询数据库中表的结构。
这四种线程池实际调用的还是ThreadPoolExecutor的构造方法。
Executors实际上调用的是ThreadPoolExecutor的构造方法(newScheduledThreadPool调用的是ScheduleThreadPoolExecutor的构造),我们看一下ThreadPoolExecutor参数最多的构造
public ThreadPoolExecutor(int corePoolSize,//线程核心线程数。线程池长期维持的线程数,即使线程处于idle状态也不会回收
int maximumPoolSize,//线程允许的最大线程数
long keepAliveTime,//空闲线程存活时间。当前线程池总数大于核心线程数时,终止多余的空闲线程的时间
TimeUnit unit,//销毁时间。超过这个时间,多余的线程会被回收
BlockingQueue<Runnable> workQueue,//存储等待执行线程的工作队列
ThreadFactory threadFactory,//创建线程工厂,定制线程的创建过程
RejectedExecutionHandler handler) //拒绝策略。当工作队列、线程池全满时如何拒绝新任务
这里有一个拒绝策略,它是如何处理的呢?
有两种方式submit()和execute()
execute没有返回值,如果不需要直到线程的结果就使用execute()
submit()返回一个Future对象,如果想知道线程结果就使用submit()提交,而且它能在主线程中通过Future的get方法捕获线程中的异常
shutdown()不再接受新的任务,之前提交的任务等执行结束再关闭线程池
shutdownNow()不再接受新的任务,试图停止池中的任务再关闭线程池,返回所有未处理线程列表
原文:https://www.cnblogs.com/dearnotes/p/12343733.html