线程池 threadpool

为什么使用线程池
使用线程池的好处是减少在创建和销毁线程上所花的时间,限制系统资源的开销,解决资源不足的问题;如果不使用线程池,有可能造成系统大量创建同类线程而导致消耗完内存或者“过度切换”的问题

jdk中提供了几种线程池
很多
比较熟悉的是
newCachedThreadPool()
newSingleThreadExecutor()
newFixedThreadPool(corePoolSize)
newScheduledThreadPool(corePoolSize)

他们底层都是创建threadPoolExecutor实例,ThreadPoolExecutor参数分别为:
corePoolSize 线程池中的核心线程数,起始线程数
maximumPoolSize 线程池中的最大线程数
keepAliveTime 当线程池中线程数量超过corePoolSize时,允许等待多长时间从workQueue中拿任务,如果在这个时间内没有拿到任务执行,那么就会被销毁。
时间单位,keepAliveTime 对应的时间单位,为TimeUnit类。
workQueue 阻塞队列,当线程池中线程数超过corePoolSize时,用于存储提交的任务。
threadFactory 线程池采用,该线程工厂创建线程池中的线程。
handler 为RejectedExecutionHandler,当线程池中线程超过maximumPoolSize时采用的,拒绝执行处理器。

执行过程中的原理是怎样的?四种线程池对应的阻塞队列?运行原理?现实中都不用他们,他们的缺陷在哪里?
newCachedThreadPool()
corePoolSize:0
maximumPoolSize: integer.max
keepAliveTime :60
TimeUnit:s
workQueue: SynchronousQueue
初始线程为0,来一个任务就创建一个线程,新创建的线程休息60s后死亡,又名在缓存中的线程池。并发高的时候无限制创建新的线程 造成oom

newSingleThreadExecutor()
corePoolSize:1
maximumPoolSize: 1
keepAliveTime :0
TimeUnit:ms 毫秒
workQueue: LinkedBlockingQueue
初始线程为1,最大线程数也是1,只有一个线程在执行任务。并发高的时候会将大量的任务加到阻塞队列汇中 造成oom

newFixedThreadPool(nThread)
corePoolSize:n
maximumPoolSize: n
keepAliveTime :0
TimeUnit:ms 毫秒
workQueue: LinkedBlockingQueue
初始线程为n,最大线程数也是n,固定的线程数。并发高的时候会将大量的任务加到阻塞队列汇中 造成oom

newScheduledThreadPool(n)
corePoolSize:n
maximumPoolSize: integer.max
keepAliveTime :0
TimeUnit:ns 纳秒
workQueue: DelayedWorkQueue
初始线程为n,最大线程数也是integer.max,,延迟队列内部数据结构是数组,容量最大为integer.max。并发高的时候会 将大量的任务加到阻塞队列汇中 造成oom ,应该还没到创建新的线程就oom了,因为要把integer.max个任务都放到队列中才会创建新的线程。
延迟队列可以让任务 沿固定的时间执行
提交任务 并设置延时执行的时间
如果提交任务 到 从队列中拿到这个任务去执行
这个期间的时间大于设置的延迟时间直接执行
否则延迟到设置的时间才执行

你们会直接用这四种线程池么
不会
这四种线程池有什么缺点,为什么不会直接使用,那你们平时都怎么使用
实际开发中,线程池不允许使用 Executors 去创建,而是通过 创建ThreadPoolExecutor 的方式,FixedThreadPool 和 SingleThreadPool,允许的请求队列长度为 Integer.MAX_VALUE,可能会堆积大量的请求,从而导致 OOM。
CachedThreadPool 和 ScheduledThreadPool,允许的创建线程数量为 Integer.MAX_VALUE,可能会创建大量的线程,从而导致 OOM

java中7个阻塞队列
https://zhuanlan.zhihu.com/p/138039565
线程池 threadpool
线程池 threadpool

jdk内置的四种拒绝策略
https://zhuanlan.zhihu.com/p/201008678

线程池 threadpool
AbortPolicy(中止策略)默认:直接抛出异常
DiscardPolicy(丢弃策略):什么也不干
DiscardOldestPolicy(弃老策略):将阻塞队列中最老的任务丢弃,并execute这个新的
CallerRunsPolicy(调用者运行策略):只要线程池没有关闭,就由调用者执行这个任务

提交、执行优先级?
1-30线程执行的时候,为什么30是先执行的,13是后执行的
线程池 threadpool
这就涉及到了提交优先级和执行优先级

提交优先级:核心线程 > 工作队列 > 非核心线程
线程池 threadpool

执行优先级(哪里的任务先被执行):核心线程 > 非核心线程 > 工作队列
如果长时间的高并发,会导致队列中的任务迟迟执行不了
线程池 threadpool

上一篇:elasticsearch RestHighLevelClient 关于document的常用操作 ---------- 删除篇


下一篇:JAVA做敏感词统计——DFA 算法