本文共 3609 字,大约阅读时间需要 12 分钟。
线程池概念 |
线程池可以简单的看作是一个“容器
”,当我们的程序在第一次启动的时候,就创建多个线程,放到这个容器
中,在需要使用线程来执行某个任务的时候,就直接到这个容器中来取一个线程使用,当该任务执行完毕之后,再将此线程回收到容器中,等待下一个被执行的任务来使用。
以前我们程序中要执行一个任务,需要先new
一个线程用来执行这个任务,执行完之后,这个线程也就被销毁了,如果此时又有一个新的任务需要被执行,那么我们只能继续new
一个线程,创建……销毁……创建……销毁……,反复如此,给我们的系统带来了巨大的开销,性能大打折扣。
线程池
,我们可以直接使用。线程池
中的线程到底是如何与任务进行交互的呢? 在下面图中,线程池中我们预先创建了4个线程,每个任务在执行的时候都将会使用一个线程,到task05任务的时候发现线程池中的4个线程都被前面的4个任务使用了,那么此时他就会在任务队列中等待,当前面的4个任务执行完毕之后,会将线程回收到线程池中,此时task05任务就可以从线程池中获取一个线程来执行相应的任务了。 在java.util.concurrent包(也就是常说得J.U.C)中,提供了一个创建线程池得工厂类:Executors
。通过该类中的newFixedThreadPool()
方法可以创建一个拥有指定数量线程的线程池。
public class RunnableImpl implements Runnable { @Override public void run() { //设置线程任务 System.out.println("这里是需要线程执行的任务代码"); }}
public class test03 { public static void main(String[] args) { //创建线程数为2的一个线程池 ExecutorService executorService = Executors.newFixedThreadPool(2); //提交需要执行的任务 executorService.submit(new RunnableImpl()); //关闭线程池(注意:关闭线程池之后,线程也就不存在了,如果在关闭线程池之后又提交了需要执行的任务将会报错) executorService.shutdown(); }}
通过上面的方式,我们可以从线程池中获取线程并执行被提交的任务,如果你使用了阿里规约插件Alibaba java Coding Guidelines
,那么使用上面这种方式可能会给你提示建议使用 ThreadPoolExecutor
类来创建线程,那么使用这种方式该如何创建呢?
ThreadPoolExecutor
类的源码 new ThreadPoolExecutor对象的时候,大家可以看到提示参数如下:public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueueworkQueue) { this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, Executors.defaultThreadFactory(), defaultHandler); }
corePoolSize
:核心线程数 默认情况下,创建一个线程池之后,线程池中的线程数为0,当有任务来了,就会创建一个线程去执行任务,当线程池中的线程数量达到corePoolSize
,就会把到达的任务放到任务队列 workQueue
中。 当线程数小于corePoolSize
的时候,来了任务线程池也会优先去创建新的线程来执行新任务 如果没有设置allowCoreThreadTimeOut(true)
,则线程池中的线程数最少应该保持在corePoolSize
的数量。
maximumPoolSize
:线程池中最多能够创建的线程数量。keepAliveTime
:线程在没有任务的情况下,最多能够存活的时间。 默认的情况下,当线程池中的线程数量大于corePoolSize
的时候,该时间才会生效,也就是说:当线程数量 > corePoolSize
的时候,如果线程的空闲时间达到了keepAliveTime
,则该线程会被终止,如果该参数设置为0,则线程执行完毕之后会被立即回收。直到线程池的线程数量不大于corePoolSize
为止。
allowCoreThreadTimeOut
方法,在线程池中的线程数量不大于corePoolSize
的时候,keepAliveTime
参数也会生效,直到线程池中的线程数量为0为止。 TimeUnit
时间单位BlockingQueue
任务队列当线程池中没有空闲的线程去执行任务的时候,该任务就会被存放到此队列中。
如果任务队列已满,又有新的任务进来的时候,将会在非corePool中创建新的的线程去处理任务,也就是说:队列未满之前,所有的任务都将在任务队列中阻塞等待被执行,而不是新建一个非corePool中的线程去执行任务。ThreadPoolExecutor
创建线程池public class RunnableImpl implements Runnable { @Override public void run() { //设置线程任务 System.out.println(Thread.currentThread().getName() + "这里是需要线程执行的任务代码"); }}
public class test03 { public static void main(String[] args) { //创建线程数为2的一个线程池// ExecutorService executorService = Executors.newFixedThreadPool(2); ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 10, 500, TimeUnit.MILLISECONDS, new ArrayBlockingQueue(5)); //提交需要执行的任务 for (int i = 0; i < 11; i++) { threadPoolExecutor.execute(new RunnableImpl()); } //关闭线程池(注意:关闭线程池之后,线程也就不存在了,如果在关闭线程池之后又提交了需要执行的任务将会报错) threadPoolExecutor.shutdown(); }}
运行main
方法:
pool-1-thread-1这里是需要线程执行的任务代码pool-1-thread-1这里是需要线程执行的任务代码pool-1-thread-1这里是需要线程执行的任务代码pool-1-thread-1这里是需要线程执行的任务代码pool-1-thread-1这里是需要线程执行的任务代码pool-1-thread-1这里是需要线程执行的任务代码pool-1-thread-2这里是需要线程执行的任务代码pool-1-thread-3这里是需要线程执行的任务代码pool-1-thread-4这里是需要线程执行的任务代码pool-1-thread-5这里是需要线程执行的任务代码
因为corePoolSize
设置为5,所以最多只能同时有5个线程去执行。
拒绝
处理任务,那在线程池中,究竟有哪些拒绝策略
呢?下一篇文章专门记录。 转载地址:http://hjhwi.baihongyu.com/