对多个线程进行统一管理,避免因为频繁创建和销毁进而引起的卡顿,提供定时执行及指定间隔循环执行等功能
1:ThreadPoolExecutor
构造方法: public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory)
参数: corePoolSize: 该线程池中核心线程的数量 maximumPoolSize: 该线程池中最大线程数量 keepAliveTime: 非核心线程空闲超时的时长,超时就会被回收,核心线程的allowCoreThreadTimeOut属性设置为true时,同样作用于核心线程 unit: 上面时间属性的单位,这是一个枚举,常用的有TimeUnit.MILLISECONDS(毫秒)、TimeUnit.SECONDS(秒)、TimeUnit.MINUTES(分钟) workQueue: 线程池中的任务队列,同时指定最大任务队列数量,通过线程池的execute方法提交的Runnable对象会存储在这个参数中 threadFactory: 线程工厂，可用于设置线程名字等等，一般无须设置该参数。
示例: ThreadPoolExecutor threadPoolExecutor=new ThreadPoolExecutor(3,100,1000,TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(128)); threadPoolExecutor.execute(Runable对象);
注意事项: 1.如果线程池中的线程数量未达到核心线程的数量,那么会直接启动一个核心线程来执行任务。 2.如果线程池中的线程数量已经达到或者超过核心线程的数量,那么任务会被插入到任务队列中排队等待执行。 3.如果在步骤2中无法将任务插入到任务队列中,这往往是由于任务队列已满,这个时候如果线程数量未达到线程池规定的最大值,那么会立刻启动一个非核心线程来执行任务。 4.如果步骤3中线程数量已经达到线程池规定的最大值,那么就拒绝执行此任务,并抛出RejectedExecutionException异常。
2.FixedThreadPool
示例: ExecutorService fixedThreadPool = Executors.newFixedThreadPool(4); fixedThreadPool.execute(Runable对象);
注意事项: 它是一种线程数量固定的线程池,当线程处于空闲状态时,它们并不会被回收,除非线程池被关闭了。当所有的线程池都处于活动状态时,新任务都会处于等待状态,直到有线程空闲出来。由于核心线程不会被回收,这意味着它能够更加快速地响应外界的请求。这些核心线程没有超时机制,任务队列也没有大小限制。
3.CachedThreadPool
示例: ExecutorService cachedThreadPool = Executors.newCachedThreadPool(); cachedThreadPool.execute(Runable对象);
注意事项: 它是一种线程数量不定的线程池,它只有非核心线程,并且最大线程数为任意大(Integer.MAX_VALUE)。当线程池中的线程都处于活动状态时,线程池会创建新的线程来处理新任务,否则就会利用空闲的线程来处理新任务。线程池中的空闲线程超时机制为60秒,超过60秒就会被回收。这类线程池比较适合执行大量的、耗时较少的任务。因为超时停止的机制,它几乎是不占用任何系统资源的。
4.ScheduledThreadPool
示例: ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(4); //延迟2000ms后执行Runable对象 scheduledThreadPool.schedule(Runable对象, 2000, TimeUnit.MILLISECONDS); //延迟10ms后,每隔1000ms执行一次command scheduledThreadPool.scheduleAtFixedRate(Runable对象, 10, 1000, TimeUnit.MILLISECONDS);
注意事项: 它的核心线程数量是固定的,而非核心线程数是没有限制的,并且当非核心线程闲置时会被立即回收。这类线程池主要用于执行定时任务和具有固定周期的重复任务
5.SingleThreadExecutor
示例: ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor(); singleThreadExecutor.execute(Runable对象);
注意事项: 这类线程池内部只有一个核心线程,它确保所有的任务都在同一个线程中按顺序执行。这使得在这些任务之间不需要处理线程同步的问题。
线程池其它方法： 1.shutDown() 关闭线程池，不影响已经提交的任务 2.shutDownNow() 关闭线程池，并尝试去终止正在执行的线程 3.allowCoreThreadTimeOut(boolean value) 允许核心线程闲置超时时被回收 4.submit 一般情况下我们使用execute来提交任务，但是有时候可能也会用到submit，使用submit的好处是submit有返回值。 5.beforeExecute() - 任务执行前执行的方法 6.afterExecute() -任务执行结束后执行的方法 7.terminated() -线程池关闭后执行的方法
