这篇文章主要介绍“Java线程池的用法”，在日常操作中，相信很多人在Java线程池的用法问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Java线程池的用法”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
ThreadPoolExecutor是Java线程池中最核心的一个类。
计算
安全
数据库
网络和加速
企业服务
public interface Executor {
void execute(Runnable command);
}
public interface ExecutorService implements Executor {}
public abstract class AbstractExecutorService implements ExecutorService {}
public class ThreadPoolExecutor extends AbstractExecutorService {
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler) {
if (corePoolSize < 0 ||
maximumPoolSize <= 0 ||
maximumPoolSize < corePoolSize ||
keepAliveTime < 0)
throw new IllegalArgumentException();
if (workQueue == null || threadFactory == null || handler == null)
throw new NullPointerException();
this.acc = System.getSecurityManager() == null ?
null :
AccessController.getContext();
this.corePoolSize = corePoolSize;
this.maximumPoolSize = maximumPoolSize;
this.workQueue = workQueue;
this.keepAliveTime = unit.toNanos(keepAliveTime);
this.threadFactory = threadFactory;
this.handler = handler;
}
}核心线程池的大小
线程池允许执行的最大线程数量，当超过这个数量后，任务将存放在workQueue中。
当线程池中线程数量大于核心线程池大小时，线程执行完之后就会销毁掉，直到线程池数量不超过核心线程池大小。
keepAliveTime的单位，常见的有DAYS、HOURS、MINUTES、SECONDS、MILLISECONDS、MICROSECONDS、NANOSECONDS
阻塞队列，用于存储等待执行的任务。一般有以下几种选择
有界队列，当有新任务到来时 当实际线程数小于corePoolSize时，线程池会生成新的线程执行任务； 当实际线程数大于corePoolSize时，新任务就会加入等待队列，当等待队列满的时候，则会在实际线程不大于maximumPoolSize的前提下创建新线程去处理任务。
无界任务队列，当有新任务到来时 当实际线程数小于corePoolSize时，线程池会生成新的线程执行任务，当实际线程数大于corePoolSize时，新任务就会加入等待队列。如果创建速度大于处理速度，则队列会一直增长，直到耗尽内存。
直接提交的队列，当有新任务到来时 当实际线程数小于maximumPoolSize时，线程池会生成新的线程执行任务； 当实际线程数大于maximumPoolSize时，新任务就会加入等待队列，但队列只会保存最新提交的一个任务。
用来创建线程的工厂
表示拒绝处理任务的策略，有以下取值
ThreadPoolExecutor.AbortPolicy //丢弃任务并抛出RejectedExecutionException异常
ThreadPoolExecutor.DiscardPolicy //也是丢弃任务，但是不抛出异常。
ThreadPoolExecutor.DiscardOldestPolicy //丢弃队列最前面的任务，然后重新尝试执行任务（重复此过程）
ThreadPoolExecutor.CallerRunsPolicy //由调用线程处理该任务public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor(
0, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>());
}无界线程池，最大线程池为Integer的最大值，线程过大时可能导致OOM。
public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor(
nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>());
}固定大小的线程池。线程数量外部传入
public static ExecutorService newSingleThreadExecutor() {
return new FinalizableDelegatedExecutorService
(new ThreadPoolExecutor(
1, 1,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>()));
}单一线程池
到此，关于“Java线程池的用法”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注亿速云网站，小编会继续努力为大家带来更多实用的文章！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://my.oschina.net/qgmzzmn/blog/3089784
