[并发编程]快速解读线程池原理

2018-11-24  本文已影响12人  6cc89d7ec09f

向线程池中提交任务A

1 判断线程池线程个数是否小于当前核心线程数,是则创建新的线程来执行A任务。否则进入下一步
2 将当前线程放入工作队列中。如果没放进去则进入下一步
3 创建新的线程来执行A任务,如果创建失败则进入下一步
4 执行拒绝策略,拒绝接受A任务

创建线程执行新任务。(假设线程池未被关闭的状态)

1 判断是否创建核心线程,如果是则判断核心线程数是否达到最大值.否则是判断非核心线程数是否达到最大值
2 如果没有达到最大值则获得全局锁,创建新的worker(封装了线程和Runnable任务),放进线程池中。并启动线程

Worker的run方法

Work本身就是继承了Runnable,所以启动线程后,默认执行Work的run方法。
run方法中,将进入一个循环,先执行A任务,执行完毕后循环获取工作队列中的任务。

参数解读:

ThreadPoolExecutor预热:在创建新线程时,会获得全局锁。那将是比较大的开销。所以预热之后,应该尽量避免创建新线程,而尽可能的将任务放入队列中。
线程池的参数:
corePoolSize(线程池的基本大小):当提交一个任务到线程池时,线程池会创建一个线
程来执行任务,即使其他空闲的基本线程能够执行新任务也会创建线程,等到需要执行的任
务数大于线程池基本大小时就不再创建。如果调用了线程池的prestartAllCoreThreads()方法,
线程池会提前创建并启动所有基本线程。
unnableTaskQueue(任务队列):用于保存等待执行的任务的阻塞队列。可以选择以下几
个阻塞队列。LinkedBlockingQueue是基于链表的,吞吐量高于ArrayBlockingQueue
maximumPoolSize:线程池允许创建的最大线程数,如果使用了无界队列此参数无效
ThreadFactory:线程工厂,我们可以自己创建线程工厂来给线程池中的线程起名字
RejectedExecutionHandler:拒绝策略
1 直接抛异常
2 调用者所在线程执行任务
3 抛弃队列中最近的一个任务(等待时间最久的一个),并把本次任务加到队列中
4 直接丢弃,不处理
keepAliveTime:非核心线程的最大空闲时间
TimeUnit:时间单位

创建线程池的几种方式

1 工厂方法创建线程,通过Executors来创建已经存在的线程。
创建ThreadPoolExecutor类型的线程,有如下:
SingleThreadExecutor:单个线程的线程池,适合单线程
FixedThreadPool:固定线程数的线程池,适合负载重的服务器
CachedThreadPool:大小无界的线程池,无核心线程,按需创建线程,适合短期异步负载轻的服务器
创建ScheduledThreadPoolExecutor类型的线程。ScheduledThreadPoolExecutor和ThreadPoolExecutor比,可以延迟指定时间加载
ScheduledThreadPoolExecutor:包含若干个线程
SingleThreadScheduledExecutor:只有一个线程
2 直接使用ThreadPoolExecutor来创建线程池
这种方式比较麻烦点,需要自己配置线程池
3 直接使用ScheduledThreadPoolExecutor来创建线程池
和方法2类似

上一篇 下一篇

猜你喜欢

热点阅读