网站飘动,开发企业小程序公司,.net 创建网站项目,南通建设网站哪家好Java番外篇3——线程池
1、多线程产生的问题
多次创建并销毁线程。而创建并销毁线程的过程势必会消耗内存
2、线程池
降低系统资源消耗#xff0c;通过重用已存在的线程#xff0c;降低线程创建和销毁造成的消耗提高系统响应速度#xff0c;当有任务到达时#xff0c;通…Java番外篇3——线程池
1、多线程产生的问题
多次创建并销毁线程。而创建并销毁线程的过程势必会消耗内存
2、线程池
降低系统资源消耗通过重用已存在的线程降低线程创建和销毁造成的消耗提高系统响应速度当有任务到达时通过复用已存在的线程无需等待新线程的创建便能立即执行方便线程并发数的管控。因为线程若是无限制的创建可能会导致内存占用过多而产生OOM并且会造成cpu过度切换影响性能提供更强大的功能延时定时线程池
3、名词解释
4、java线程池
Executors类提供了4种不同的线程池 newCachedThreadPool用来创建一个可以无限扩大的线程池适用于负载较轻的场景执行短期异步任务。可以使得任务快速得到执行因为任务时间执行短可以很快结束也不会造成cpu过度切换 newFixedThreadPool创建一个固定大小的线程池因为采用无界的阻塞队列所以实际线程数量永远不会变化适用于负载较重的场景对当前线程数量进行限制。保证线程数可控不会造成线程过多导致系统负载更为严重 newScheduledThreadPool创建一个单线程的线程池适用于需要保证顺序执行各个任务 newSingleThreadExecutor适用于执行延时或者周期性任务
5、四种线程池的使用
5.1、newSingleThreadExecutor
单个线程线程池只有一个线程的线程池阻塞队列使用的是LinkedBlockingQueue,若有多余的任务提交到线程池中则会被暂存到阻塞队列待空闲时再去执行。按照先入先出的顺序执行任务
public class Test {public static void main(String[] args) {ExecutorService executorService Executors.newSingleThreadExecutor();for (int i 0; i 10; i) {executorService.execute(()-{System.out.println(Thread.currentThread().getName());});}executorService.shutdown();}
}5.2、newFixedThreadPool
固定大小的线程池可以指定线程池的大小该线程池corePoolSize和maximumPoolSize相等阻塞队列使用的是LinkedBlockingQueue大小为整数最大值
该线程池中的线程数量始终不变当有新任务提交时线程池中有空闲线程则会立即执行如果没有则会暂存到阻塞队列。对于固定大小的线程池不存在线程数量的变化。同时使用无界的LinkedBlockingQueue来存放执行的任务。当任务提交十分频繁的时候LinkedBlockingQueue
迅速增大存在着耗尽系统资源的问题。而且在线程池空闲时即线程池中没有可运行任务时它也不会释放工作线程还会占用一定的系统资源需要shutdown
public class Test {public static void main(String[] args) {ExecutorService executorService Executors.newFixedThreadPool(5);for (int i 0; i 10; i) {executorService.execute(()-{System.out.println(Thread.currentThread().getName());});}executorService.shutdown();}
}5.3、newCachedThreadPool
缓存线程池缓存的线程默认存活60秒。线程的核心池corePoolSize大小为0核心池最大为Integer.MAX_VALUE,阻塞队列使用的是SynchronousQueue。是一个直接提交的阻塞队列 他总会迫使线程池增加新的线程去执行新的任务。在没有任务执行时当线程的空闲时间超过keepAliveTime60秒则工作线程将会终止被回收当提交新任务时如果没有空闲线程则创建新线程执行任务会导致一定的系统开销。如果同时又大量任务被提交而且任务执行的时间不是特别快那么线程池便会新增出等量的线程池处理任务这很可能会很快耗尽系统的资源
public class Test {public static void main(String[] args) {ExecutorService executorService Executors.newCachedThreadPool();for (int i 0; i 10; i) {executorService.execute(()-{System.out.println(Thread.currentThread().getName());});}
// for (int i 0; i 100; i) {
// executorService.execute(()-{
// System.out.println(Thread.currentThread().getName());
// });
// }executorService.shutdown();}
}5.4、newScheduledThreadPool
候补
5.5、原生创建
public class Test {public static void main(String[] args) {ExecutorService executorService new ThreadPoolExecutor(3,5,10l,TimeUnit.SECONDS,new ArrayBlockingQueue(3),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());for (int i 0; i 5; i) {executorService.execute(()-{System.out.println(Thread.currentThread().getName());});}executorService.shutdown();}
}5.5.1、7大参数 corePoolSize线程池基本大小当向线程池提交一个任务时若线程池已创建的线程数小于corePoolSize即便此时存在空闲线程也会通过创建一个新线程来执行该任务直到已创建的线程数大于或等于corePoolSize时除了利用提交新任务来创建和启动线程按需构造也可以通过 prestartCoreThread() 或 prestartAllCoreThreads() 方法来提前启动线程池中的基本线程。 maximumPoolSize线程池最大大小线程池所允许的最大线程个数。当队列满了且已创建的线程数小于maximumPoolSize则线程池会创建新的线程来执行任务。另外对于无界队列可忽略该参数 keepAliveTime线程存活保持时间当线程池中线程数大于核心线程数时线程的空闲时间如果超过线程存活时间那么这个线程就会被销毁直到线程池中的线程数小于等于核心线程数 workQueue任务队列用于传输和保存等待执行任务的阻塞队列 threadFactory线程工厂用于创建新线程。threadFactory创建的线程也是采用new Thread()方式threadFactory创建的线程名都具有统一的风格pool-m-thread-nm为线程池的编号n为线程池内的线程编号 handler线程饱和策略当线程池和队列都满了再加入线程会执行此策略
5.5.2、四大拒绝策略
AbortPolicy抛异常CallerRunsPolicy哪来的回哪去DiscardPolicy抛弃任务DiscardOldestPolicy替换旧的任务
5.5.3、最大线程数
CPU密集型依据CPU的核数设置Runtime.getRuntime().availableProcessors()IO密集型通常设置IO任务的两倍
