Java多线程-ThreadPool线程池-3(五)
除了可以通过ThreadPoolExecutor自定义线程池外,同Stream API中的Collectors一样,多线程里的Executors类也提供了一组相关的线程池工具,可以直接拿来用,不用考虑用什么队列合适的问题。
Javac除了传统的四大线程池工具:
1、newFixedThreadPool定长线程池
2、newCachedThreadPool缓存线程池
3、newSingleThreadExecutor单线程线程池
4、newScheduledThreadPool任务调度线程池
还包括了Java8新增的newWorkStealingPool抢占式线程池,目前这个用的不多,还是以之前的四大类线程池为主。
一、newFixedThreadPool
newFixedThreadPool定长线程池,顾名思义,就是它的线程池的大小是固定的,好比一个水池只能装10个立方的水量,11个立方肯定就装不下了。在newFixedThreadPool定长线程池中,c=m(也就是corePoolSize = maximumPoolSize),默认为无界队列,用代码来示例:
// 定长线程池 ExecutorService service1 = Executors.newFixedThreadPool(3); for (int i = 0; i < 10; i++) { System.out.println("创建线程 " + i); service1.execute(() -> System.out.println("当前线程 " + Thread.currentThread().getName())); } service1.shutdown();
可以看到,虽然创建了10个线程,但始终只有3个在工作。定长线程池在实际中用的比较多,尤其是一些可估算工作量的任务时。它的程序流程图是这样的:
二、newCachedThreadPool
newCachedThreadPool缓存线程池不会限制池中的线程数量,可以无限往里增加,直到线程数量超出最大整数范围,一般不会用这种方式,因为可能会因为程序故障而把机器拖垮。代码也很简单:
// 缓存线程池 ExecutorService service2 = Executors.newCachedThreadPool(); for (int i = 0; i < 1_000_000_000; i++) { System.out.println("创建线程 " + i); service2.execute(() -> System.out.println("当前线程 " + Thread.currentThread().getName())); } service2.shutdown();
我希望创造10亿个线程,计算机照单全收。我花了很长时间,它都没有停下来的意思
所以我只好强制让它休息了。
它的程序流程图是这样的:
三、newSingleThreadExecutor
newSingleThreadExecutor单线程线程池是定长线程池的一个特例,它的线程池长度始终为1,也就是c=m=1,它的代码:
// 单线程线程池 ExecutorService service3 = Executors.newSingleThreadExecutor(); for (int i = 0; i < 10; i++) { System.out.println("创建线程 " + i); service3.execute(() -> System.out.println("当前线程 " + Thread.currentThread().getName())); } service3.shutdown();
执行后可以看到,它始终只能创建一个线程。
四、newScheduledThreadPool
最后一个是任务调度线程池,顾名思义,需要执行某些任务调度时可以用到,例如:3个线程每秒执行1次的(仅执行1次):
// 任务调度线程池 ScheduledExecutorService service4 = Executors.newScheduledThreadPool(3); for (int i = 0; i < 10; i++) { // 延迟1秒后执行,仅执行1次 service4.schedule(() -> System.out.println("当前线程 " + Thread.currentThread().getName()), 1, TimeUnit.SECONDS); } service4.shutdown();
或者3个线程每3秒各执行1次的:
// 任务调度线程池 ScheduledExecutorService service5 = Executors.newScheduledThreadPool(3); for (int i = 0; i < 10; i++) { // 延迟1秒后执行,每3秒执行1次 service4.scheduleAtFixedRate(() -> System.out.println("当前线程 " + Thread.currentThread().getName()), 1, 3, TimeUnit.SECONDS); } service5.shutdown();
线程池的基本内容其实并不多,主要还是要在日常开发中实际使用,多用多练才能熟能生巧。
相关文章
- 深入探讨Java中的异常与错误处理
- 研究学习Kotlin的一些方法
- 数据显示Java热度持续下落,日子屈指可数?
- 2017年5月编程语言排行榜:Java与C语言优势正开始缩小
- Java多线程之内置锁与显示锁
- Java线程池的理论与实践
- 白话阿里巴巴Java开发手册(编程规约)
- 关于Java你不知道的十件事
- Java服务化系统线上应急和技术攻关,你必须掌握的Linux命令
- Java实现高斯模糊和图像的空间卷积
- Java阻塞队列实现原理分析
- NPM使用技巧
- Node.js对Java开发者而言是什么?
- Java反射机制应用实践
- 理解RxJava中的Single和Completable
- 2017年你不能错过的Java类库
- 大规模集群下的Hadoop NameNode
- 从源码解密Spark内存管理
- 2017年3月编程语言排行榜:Swift首次进入前十
- JVM热点技术:Java类的加载机制