多线程编程基础(二)-- 线程池的使用

前言

多线程编程基础(一)中,讲到了线程最基本的使用方法。可是在阿里的开发规范上,这是不值得推荐的。能够在idea中下一个Alibaba Java Coding Guidelines,来纠正咱们开发时的习惯。 java

插件的使用效果

思考

  1. 如何使用多线程?
  2. 如此使用多线程开发的好处是什么?

线程池

就上面的第一个问题,咱们引入的是一个线程池的概念。想来以前在享元模式中,咱们就说起过缓冲池的概念,那么线程池是什么样的呢?编程

线程池执行模型

从图中咱们能够得到信息有设计模式

  1. 任务队列:workQueue
  2. 核心线程数:coolPoolSize
  3. 最大线程数:maximumPoolSize
  4. 饱和策略:RejectedExecutionHandler

固然,其实须要的参数还有不少。多线程

// ThreadPoolExecutor的构造函数
ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler)
复制代码

线程池分为不少种类,最经常使用的是这四种:FixedThreadPool、CachedThreadPool、SingleThreadExecutor、ScheduledThreadPool。并发

FixedThreadPool

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

从填入的函数能够看出最大线程数和核心线程数的数量相同,也就意味着只有核心线程了,多出的任务,将会被放置到LinkedBlockingQueue中。ide

CachedThreadPool

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

没有核心线程,最大线程数为无穷,也就意味着所有都是非核心线程。这样的线程池更适合去完成大量须要当即处理,可是耗时短的任务。函数

SingleThreadExecutor

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

核心线程数和最大线程数相同,且都为1,也就意味着任务是按序工做的。post

ScheduledThreadPool

public static ScheduledExecutorService newScheduledThreadPool( int corePoolSize, ThreadFactory threadFactory) {
        return new ScheduledThreadPoolExecutor(corePoolSize, threadFactory);
}

public ScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory) {
        super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
              new DelayedWorkQueue(), threadFactory);
}
复制代码

从函数名就已经说明了,是一种定时任务。其实就个人思考,他能够用于实现各类各样功能相似的其余线程池。由于DelayedWorkQueue队列中你能够插入一个马上须要执行的任务。学习

使用线程池的好处

  • 线程的复用

每次使用线程咱们是否是须要去建立一个Thread,而后start(),而后就等结果,最后的销毁就等着垃圾回收机制来了。 可是问题是若是有1000个任务呢,你要建立1000个Thread吗?若是建立了,那回收又要花多久的时间?ui

  • 控制线程的并发数

存在核心线程和非核心线程,还有任务队列,那么就能够保证资源的争夺是处于一个尽可能可控的状态的。

  • 线程的管理

以上就是个人学习成果,若是有什么我没有思考到的地方或是文章内存在错误,欢迎与我分享。


相关文章推荐:

多线程编程基础(一)-- 线程的使用

JVM必备基础知识(一) -- 类的加载机制

聊一聊设计模式(一)-- 六大原则

相关文章
相关标签/搜索