Java线程池的用法
这篇文章主要介绍"Java线程池的用法"，在日常操作中，相信很多人在Java线程池的用法问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"Java线程池的用法"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
ThreadPoolExecutor
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 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; }} corePoolSize
核心线程池的大小
maximumPoolSize
线程池允许执行的最大线程数量，当超过这个数量后，任务将存放在workQueue中。
keepAliveTime
当线程池中线程数量大于核心线程池大小时，线程执行完之后就会销毁掉，直到线程池数量不超过核心线程池大小。
unit
keepAliveTime的单位，常见的有DAYS、HOURS、MINUTES、SECONDS、MILLISECONDS、MICROSECONDS、NANOSECONDS
workQueue
阻塞队列，用于存储等待执行的任务。一般有以下几种选择
ArrayBlockingQueue
有界队列，当有新任务到来时 当实际线程数小于corePoolSize时，线程池会生成新的线程执行任务； 当实际线程数大于corePoolSize时，新任务就会加入等待队列，当等待队列满的时候，则会在实际线程不大于maximumPoolSize的前提下创建新线程去处理任务。
LinkedBlockingQueue
无界任务队列，当有新任务到来时 当实际线程数小于corePoolSize时，线程池会生成新的线程执行任务，当实际线程数大于corePoolSize时，新任务就会加入等待队列。如果创建速度大于处理速度，则队列会一直增长，直到耗尽内存。
SynchronousQueue
直接提交的队列，当有新任务到来时 当实际线程数小于maximumPoolSize时，线程池会生成新的线程执行任务； 当实际线程数大于maximumPoolSize时，新任务就会加入等待队列，但队列只会保存最新提交的一个任务。
threadFactory
用来创建线程的工厂
handler
表示拒绝处理任务的策略，有以下取值
ThreadPoolExecutor.AbortPolicy //丢弃任务并抛出RejectedExecutionException异常ThreadPoolExecutor.DiscardPolicy //也是丢弃任务，但是不抛出异常。 ThreadPoolExecutor.DiscardOldestPolicy //丢弃队列最前面的任务，然后重新尝试执行任务（重复此过程）ThreadPoolExecutor.CallerRunsPolicy //由调用线程处理该任务
预创建线程池
ExecutorService newCachedThreadPool()
public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor( 0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue());} 无界线程池，最大线程池为Integer的最大值，线程过大时可能导致OOM。
ExecutorService newFixedThreadPool()
public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor( nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue()); } 固定大小的线程池。线程数量外部传入
ExecutorService newSingleThreadExecutor()
public static ExecutorService newSingleThreadExecutor() { return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor( 1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue())); } 单一线程池
到此，关于"Java线程池的用法"的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注网站，小编会继续努力为大家带来更多实用的文章！
