乐趣区

关于java:Java并发线程之线程池

jiezi

初始化线程池后, 把工作丢进去, 期待调度就能够了, 应用起来比拟不便。
JAVA 中 Thread 是线程类, 不倡议间接应用 Thread 执行工作, 在并发数量比拟多的状况下, 每个线程都是执行一个很短的工夫就工作完结了, 这样频繁创立线程会大大降低零碎的效率, 因为频繁的创立和销毁线程须要工夫。而线程池能够复用, 就是执行完一个工作, 并不销毁, 而是能够继续执行其它工作。

Thread 的弊病

  • 每次new Thread() 创建对象, 性能差。
  • 线程不足对立治理, 可能无限度创立线程, 相互竞争, 有可能占用过多系统资源导致死机或 OOM。
  • 不能多执行, 定期执行, 线程中断

线程池的长处

  • 重用存在的线程, 缩小对象创立, 沦亡的开销, 性能佳, 升高资源耗费。
  • 能够管制最大并发线程数, 进步系统资源利用率, 同时防止过多资源竞争, 防止阻塞, 进步响应速度。
  • 提供定时执行, 定期执行, 单线程, 并发数管制等性能, 以进步线程的可管理性。

阿里公布的 Java 开发手册中强制线程池不容许应用 Executors 去创立，而是通过 ThreadPoolExecutor 的形式，这样的解决形式让写的同学更加明确线程池的运行规定，躲避资源耗尽的危险。

Executors 利用工厂模式向咱们提供了 4 种线程池实现形式，然而并不举荐应用，起因是应用 Executors 创立线程池不会传入相干参数而应用默认值所以咱们经常疏忽了那些重要的参数（线程池大小、缓冲队列的类型等），而且默认应用的参数会导致资源节约，不可取。

ThreadPoolExecutor介绍

构造函数和参数

java.uitl.concurrent.ThreadPoolExecutor类是线程池中最外围的一个类。

public class ThreadPoolExecutor extends AbstractExecutorService {
    /** 构造函数 1 */
    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue) {}
                              
    /** 构造函数 2 */
    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory) {}
                              
    /** 构造函数 3 */
    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              RejectedExecutionHandler handler) {}
                              
    /** 构造函数 4 */
    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler) {}}

ThreadPoolExecutor 类中提供了四个构造方法，在构造函数 4 中，参数最多，通过观察其余 3 个构造函数，发现后面三个结构器都是调用的第四个结构器进行的初始化工作。

结构器中各个参数的含意

corePoolSize 外围线程池的大小, 在创立了线程池后, 默认状况下, 线程池中没有任何的线程池, 而是等工作过去了再去创立线程执行工作。除非调用了预创立线程的办法, 即在没有工作到来之前就创立 corePoolSize 个线程或者一个线程。当线程池中的线程数量达到 corePoolSize 后, 就会把达到的工作放到缓存队列外面。

  • prestartCoreThread() : 预创立一个外围线程，使其闲置期待工作。
  • prestartAllCoreThreads() : 启动所有外围线程，导致它们空闲地期待工作。

maxnumPoolSize 线程池中最大的线程数, 是一个十分重要的参数, 它示意在线程池中最多能创立多少线程。

keepAliveTime 示意线程在没有工作执行时最多放弃多久工夫会终止。默认状况下, 只有当线程池中的线程数大于 corePoolSize 时,keepAliveTime才会起作用, 即当线程池中的线程数大于 corePoolSize, 如果一个线程的闲暇工夫达到keepAliveTime, 则会终止直到线程池中的线程数量不大于corePoolSize。然而如果调用了allowCoreThreadTimeOut(boolean) 办法, 在线程池中线程数不大于 corePoolSize 时,keepAliveTime参数也会启作用, 直到线程池中的线程数为 0。

unit 参数 keepAliveTime 的工夫单位, 有 7 种取值, 在 TimeUnit 类中有 7 种动态属性。

  • TimeUnit.DAYS : 以 天 为单位；
  • TimeUnit.HOURS : 以 小时 为单位；
  • TimeUnit.MINUTES : 以 分钟 为单位；
  • TimeUnit.SECONDS : 以 秒 为单位；
  • TimeUnit.MILLISECONDS : 以 毫秒 为单位；
  • TimeUnit.MICROSECONDS : 以 微秒 为单位；
  • TimeUnit.NANOSECONDS : 以 纳秒 为单位；

workQueue一个阻塞队列, 用来存储期待执行的工作, 这个参数的抉择也很重要, 会对线程池的运行过程产生重大影响, 个别有以下几种抉择。

  • ArrayBlockingQueue: 基于数组的先进先出队列, 创立时必须指定大小。
  • LinkedBlockingQueue: 基于链表的先进先出队列, 若果创立时没有指定此队列的大小, 则默认为Integer.MAX_VALUE。
  • SynchronousQueue: 这个队列比拟非凡, 它不会保留提交的工作, 而是间接新建一个线程来执行新的工作。

threadFactory线程工厂, 次要用来创立线程。线程池最重要的一项工作, 就是在满足某些条件状况下创立线程。在 ThreadPoolExecutor 线程池中, 创立线程的操作时交给 ThreadFactoty 来实现。应用线程池, 就必须要指定 threadFactory。如果咱们的结构器中没有指定应用ThreadFactory, 这个时候ThreadPoolExecutor 就会应用默认的ThreadFactory:DefaultThreadFactory

handler 在 ThreadPoolExecutor 线程池中还有一个重要的接口：RejectedExecutionHandler。当提交给线程池的某一个新工作无奈间接被线程池中“外围线程”间接解决，又无奈退出期待队列，也无奈创立新的线程执行；又或者线程池曾经调用 shutdown()办法进行了工作；又或者线程池不是处于失常的工作状态；这时候 ThreadPoolExecutor 线程池会回绝解决这个工作，触发创立 ThreadPoolExecutor 线程池时定义的 RejectedExecutionHandler 接口的实现，示意当回绝解决工作时的策略，有以下四种取值，四种值都为其动态外部类：

  • ThreadPoolExecutor.AbortPolicy：抛弃工作并抛出 RejectedExecutionException 异样
  • ThreadPoolExecutor.DiscardPolicy：也是抛弃工作，然而不抛出异样。
  • ThreadPoolExecutor.DiscardOldestPolicy：抛弃队列最后面的工作，而后从新尝试执行新提交的工作。

ThreadPoolExecutor执行 execute 办法分上面 4 种状况

  • 如果以后运行的线程少于corePoolSize, 则创立新的线程来执行工作(执行这一步骤须要获取全局锁)
  • 如果运行的线程等于或者多于corePoolSize, 则将工作退出到BlockingQueue
  • 如果无奈将工作退出BlockingQueue(队列已满), 则创立新的线程来解决工作(执行这一步骤须要获取全局锁)
  • 如果创立新线程将以后运行的线程超出 maxnumPoolSize, 工作被回绝, 并调用RejectedExecutionHandler.rejectedExecution() 办法。

关注微信公众号:【入门小站】, 解锁更多知识点

退出移动版