java~线程池的总结
线程的创建和效率都需要消耗处理器(cpu)的资源,所以我们在使用线程时需要注意,你的每一个动作都是需要为它买单的,也正是因为线程的使用需要谨慎,所以java对线程的管理也进行了封装,就是今天要说的线程池,目前java主要封装了大概4大种类型的线程池,下面简单来介绍一下。
四大类型的线程池
- newcachedthreadpool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。
- newfixedthreadpool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。
- newscheduledthreadpool 创建一个定长线程池,支持定时及周期性任务执行。
- newsinglethreadexecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(fifo, lifo, 优先级)执行。
线程池里主要的三个参数
corepoolsize:
线程池的基本大小,即在没有任务需要执行的时候线程池的大小,并且只有在工作队列满了的情况下才会创建超出这个数量的线程。这里需要注意的是:在刚刚创建threadpoolexecutor的时候,线程并不会立即启动,而是要等到有任务提交时才会启动,除非调用了prestartcorethread/prestartallcorethreads事先启动核心线程。再考虑到keepalivetime和allowcorethreadtimeout超时参数的影响,所以没有任务需要执行的时候,线程池的大小不一定是corepoolsize。
maximumpoolsize:
线程池中允许的最大线程数,线程池中的当前线程数目不会超过该值。如果队列中任务已满,并且当前线程个数小于maximumpoolsize,那么会创建新的线程来执行任务。这里值得一提的是largestpoolsize,该变量记录了线程池在整个生命周期中曾经出现的最大线程个数。为什么说是曾经呢?因为线程池创建之后,可以调用setmaximumpoolsize()改变运行的最大线程的数目。
poolsize:
线程池中当前线程的数量,当该值为0的时候,意味着没有任何线程,线程池会终止;同一时刻,poolsize不会超过maximumpoolsize。
相关实例代码
newcachedthreadpool缓存池
/** * newcachedthreadpool线程自动分配,不能控制上限. */ @test public void newcachedthreadpool() { executorservice cachedthreadpool = executors.newcachedthreadpool(); for (int i = 0; i < 20; i++) { cachedthreadpool.execute(new runnable() { @override public void run() { logger.info("cachedthreadpool测试代码:{}", thread.currentthread().getname()); } }); } }
newfixedthreadpool可控制上线的线程池
/** * newfixedthreadpool控制最大的线程数,可以控制上限. */ @test public void newfixedthreadpool() { executorservice fixedthreadpool = executors.newfixedthreadpool(5); for (int i = 0; i < 20; i++) { fixedthreadpool.execute(new runnable() { @override public void run() { logger.info("fixedthreadpool测试代码:{}", thread.currentthread().getname()); } }); } }
newsinglethreadexecutor只有一个线程的线程池,只有当线程出现异常后才会建立新的线程代替它
/** * newsinglethreadexecutor只有一个线程,当这个线程因为异常结束,会有一个新的线程来替代它. */ @test public void newsinglethreadexecutor() { executorservice newsinglethread = executors.newsinglethreadexecutor(); for (int i = 0; i < 20; i++) { newsinglethread.execute(new runnable() { @override public void run() { logger.info("newsinglethread测试代码:{}", thread.currentthread().getname()); } }); } }
newscheduledthreadpool带有调度功能的线程池,可以执行周期性的任务
/** * newscheduledthreadpool按着时间间隔进行周期性任务 */ @test public void newscheduledthreadpool() throws interruptedexception { scheduledexecutorservice executor = executors.newscheduledthreadpool(5); executor.scheduleatfixedrate(() -> { long start = new date().gettime(); system.out.println("scheduleatfixedrate 开始执行时间:" + dateformat.gettimeinstance().format(new date())); try { thread.sleep(1000); } catch (interruptedexception e) { e.printstacktrace(); } long end = new date().gettime(); system.out.println("scheduleatfixedrate 执行花费时间=" + (end - start) / 1000 + "m"); system.out.println("scheduleatfixedrate 执行完成时间:" + dateformat.gettimeinstance().format(new date())); system.out.println("======================================"); }, 0, 1, timeunit.seconds);//initialdelay初始化延时,period:两次执行最小间隔时间 thread.sleep(1000 * 10); }
上一篇: [HTTP] http中的502 , 504 , 499 500都是啥
下一篇: java jar包
推荐阅读
-
Java多线程的用法详解
-
java线程之join方法的使用介绍
-
Java concurrency线程池之线程池原理(四)_动力节点Java学院整理
-
Java concurrency线程池之线程池原理(三)_动力节点Java学院整理
-
Java concurrency线程池之Callable和Future_动力节点Java学院整理
-
浅谈Android 的线程和线程池的使用
-
java 线程的生命周期详解
-
java多线程之wait(),notify(),notifyAll()的详解分析
-
Spring Boot利用@Async异步调用:ThreadPoolTaskScheduler线程池的优雅关闭详解
-
Android 中三种启用线程的方法总结