文章目录

一、创建线程池的方式一般有两种：
二、通过Executors工厂创建
三、通过new
ThreadPoolExecutor(coreThreadSize,
max...
...)

一、创建线程池的方式一般有两种：

通过Executors工厂方法创建
通过new ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, newThreadFactoryBuilder().setNameFormat("thread-name-%").build(), new ThreadPoolExecutor.AbortPolicy())

二、通过Executors工厂创建

1. Executors.newSingleThreadExecutor()

这个线程池只有一个核心线程在工作，也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束，那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。

public static ExecutorService newSingleThreadExecutor() {
    return new FinalizableDelegatedExecutorService
        (new ThreadPoolExecutor(1, 1,
                                0L, TimeUnit.MILLISECONDS,
                                new LinkedBlockingQueue<Runnable>()));
}

corePoolSize：1，只有一个核心线程在工作
maximumPoolSize：1
keepAliveTime：0L
TimeUnit：TimeUnit.MILLISECONDS 时间单位是毫秒
workQueue：new LinkedBlockingQueue ()，其缓冲队列是无界的

2. Executors.newFixedThreadPool(n)

FixedThreadPool 是固定大小的线程池，只有核心线程。每次提交一个任务就创建一个线程，直到线程达到线程池的最大大小。线程池的大小一旦达到最大值就会保持不变，如果某个线程因为执行异常而结束，那么线程池会补充一个新线程。FixedThreadPool 多数针对一些很稳定很固定的正规并发线程，多用于服务器。

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue<Runnable>());
}

corePoolSize：nThreads
maximumPoolSize：nThreads
keepAliveTime：0L
TimeUnit：TimeUnit.MILLISECONDS 时间单位是毫秒
workQueue：new LinkedBlockingQueue ()，其缓冲队列是无界的

3. Executors.newCachedThreadPool()

CachedThreadPool 是无界线程池，如果线程池的大小超过了处理任务所需要的线程，那么就会回收部分空闲（60 秒不执行任务）线程，当任务数增加时，此线程池又可以智能的添加新线程来处理任务。线程池大小完全依赖于操作系统（或者说 JVM）能够创建的最大线程大小。SynchronousQueue 是一个是缓冲区为 1 的阻塞队列。缓存型池子通常用于执行一些生存期很短的异步型任务，因此在一些面向连接的 daemon 型 SERVER 中用得不多。但对于生存期短的异步任务，它是 Executor 的首选。

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue<Runnable>());
}

corePoolSize：0
maximumPoolSize：Integer.MAX_VALUE
keepAliveTime：60L
TimeUnit：TimeUnit.SECONDS时间单位是秒
workQueue：new SynchronousQueue ()，一个是缓冲区为 1 的阻塞队列。

4. Executors.newScheduledThreadPool(n)

ScheduledThreadPool核心线程池固定，大小无限的线程池。此线程池支持定时以及周期性执行任务的需求。创建一个周期性执行任务的线程池。如果闲置，非核心线程池会在 DEFAULT_KEEPALIVEMILLIS 时间内回收。

public ScheduledThreadPoolExecutor(int corePoolSize) {
    super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
          new DelayedWorkQueue());
}

corePoolSize：corePoolSize
maximumPoolSize：Integer.MAX_VALUE
keepAliveTime：DEFAULT_KEEPALIVE_MILLIS
workQueue：new DelayedWorkQueue()

三、通过new ThreadPoolExecutor(coreThreadSize, max... ...)

具体的详情请看之前的文章线程池的理解以及使用

一、创建线程池的方式一般有两种：

通过Executors工厂方法创建
通过new ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, newThreadFactoryBuilder().setNameFormat("thread-name-%").build(), new ThreadPoolExecutor.AbortPolicy())

二、通过Executors工厂创建

1. Executors.newSingleThreadExecutor()

public static ExecutorService newSingleThreadExecutor() {
    return new FinalizableDelegatedExecutorService
        (new ThreadPoolExecutor(1, 1,
                                0L, TimeUnit.MILLISECONDS,
                                new LinkedBlockingQueue<Runnable>()));
}

corePoolSize：1，只有一个核心线程在工作
maximumPoolSize：1
keepAliveTime：0L
TimeUnit：TimeUnit.MILLISECONDS 时间单位是毫秒
workQueue：new LinkedBlockingQueue ()，其缓冲队列是无界的

2. Executors.newFixedThreadPool(n)

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue<Runnable>());
}

corePoolSize：nThreads
maximumPoolSize：nThreads
keepAliveTime：0L
TimeUnit：TimeUnit.MILLISECONDS 时间单位是毫秒
workQueue：new LinkedBlockingQueue ()，其缓冲队列是无界的

3. Executors.newCachedThreadPool()

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue<Runnable>());
}

corePoolSize：0
maximumPoolSize：Integer.MAX_VALUE
keepAliveTime：60L
TimeUnit：TimeUnit.SECONDS时间单位是秒
workQueue：new SynchronousQueue ()，一个是缓冲区为 1 的阻塞队列。

4. Executors.newScheduledThreadPool(n)

public ScheduledThreadPoolExecutor(int corePoolSize) {
    super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
          new DelayedWorkQueue());
}

corePoolSize：corePoolSize
maximumPoolSize：Integer.MAX_VALUE
keepAliveTime：DEFAULT_KEEPALIVE_MILLIS
workQueue：new DelayedWorkQueue()

三、通过new ThreadPoolExecutor(coreThreadSize, max... ...)

具体的详情请看之前的文章线程池的理解以及使用

本文作者：Java技术债务
原文链接： https://cuizb.top/myblog/article/1646793688
版权声明： 本博客所有文章除特别声明外，均采用 CC BY 3.0 CN协议进行许可。转载请署名作者且注明文章出处。

Java技术债务

Java创建线程池的方式

文章目录

一、创建线程池的方式一般有两种：

二、通过Executors工厂创建

1. Executors.newSingleThreadExecutor()

2. Executors.newFixedThreadPool(n)

3. Executors.newCachedThreadPool()

4. Executors.newScheduledThreadPool(n)

三、通过new ThreadPoolExecutor(coreThreadSize, max... ...)

一、创建线程池的方式一般有两种：

二、通过Executors工厂创建

1. Executors.newSingleThreadExecutor()

2. Executors.newFixedThreadPool(n)

3. Executors.newCachedThreadPool()

4. Executors.newScheduledThreadPool(n)

三、通过new ThreadPoolExecutor(coreThreadSize, max... ...)

Java技术债务

最新评论