Java多线程之线程池源码（线程池种类）

50 阅读 0 评论 33 点赞

我是靠谱客的博主危机宝马，最近开发中收集的这篇文章主要介绍Java多线程之线程池源码（线程池种类），觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

多线程之线程池

创建固定大小的线程

public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor(nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue());
}
创建缓存线程池

public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS,
new SynchronousQueue());
}
- 用线程池创建定时器
  
  public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
  return new ScheduledThreadPoolExecutor(corePoolSize);
  }
  public ScheduledThreadPoolExecutor(int corePoolSize) {
  super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
  new DelayedWorkQueue());
  }
  public ThreadPoolExecutor(int corePoolSize,
  int maximumPoolSize,
  long keepAliveTime,
  TimeUnit unit,
  BlockingQueue workQueue) {
  this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
  Executors.defaultThreadFactory(), defaultHandler);
  }
- 创建单一线程池
  
  public static ExecutorService newSingleThreadExecutor() {
  return new FinalizableDelegatedExecutorService
  (new ThreadPoolExecutor(1, 1,
  0L, TimeUnit.MILLISECONDS,
  new LinkedBlockingQueue()));
  }
解释；通过分析源码我们知道，最终都会调用 ThreadPoolExecutor 的构造方法来创建线程池，ThreadPoolExecutor 是ExecutorService（执行者服务）的默认实现类，是Executor(执行者接口)的子接口，目的就是就是通过execute（）方法将任务提交给执行者，或者通过submit（）方法将任务提交给执行者（底层还是调用execute（））

Future<> submit(Runnable task);
public Future<> submit(Runnable task) {
if (task == null) throw new NullPointerException();
RunnableFuture ftask = newTaskFor(task, null);
execute(ftask);
return ftask;
}