简单明了Java线程池

线程池

线程池从功能上来看,就是一个任务管理器。在Java中,Executor接口是线程池的根接口,其中只包含一个方法:

  void execute(Runnable command);  // 执行任务

ExecutorService继承了Executor接口,提供了一些线程池的基础方法:

  void shutdown(); 		// 关闭线程池(不接受新任务,但是旧任务会执行)
  List<Runnable> shutdownNow(); 	// 关闭线程池,返回待执行任务
  boolean isShutdown(); 	// 线程池是否会关闭
  boolean isTerminated(); 	// 关闭之前所有任务是否被关闭。(必须先执行过shutdown)
  ....

再往下是两种线程池的实现:ThreadPoolExecutor和ForkJoinPool。ThreadPoolExecutor中维护了一个BlockingQueue阻塞队列保存所有的待执行任务,而ForkJoinPool中每一个线程都有自己的BlockingQueue用来存储任务。

ThreadPoolExecutor

在ThreadPoolExecutor的构造方法中,需要提供几个参数:corePoolSize、maximumPoolSize、keepAliveTime、BlockingQueue、RejectedExecutionHandler。其中corePoolSize表示当前线程池维护几个线程,maximumPoolSize表示允许的最大线程数。keepAliveTime表示如果当前线程数在
corePoolSize和maximumPoolSize之间时,允许在多久时间内保持存活等待新任务。BlockingQueue是保存任务的阻塞队列,RejectedExecutionHandler是不同的拒绝策略。

    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              RejectedExecutionHandler handler) {
        this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
             Executors.defaultThreadFactory(), handler);
    }
  • 那么ThreadPoolExecutor中是如何创建新线程呢?

简单明了Java线程池

上一篇:十大经典预测算法


下一篇:java -- md5 加密