Java Executors(线程池)
Sun在Java5中,对 Java线程的类库做了大量的扩展,其中线程池就是Java5的新特征之一,除了线程池之外,还有很多多线程相关的内容,为多线程的编程带来了极大便利。为了编写高效稳定可靠的多线程程序,线程部分的新增内容显得尤为重要。
有关Java5线程新特征的内容全部在java.util.concurrent下面,里面包含数目众多的接口和类,熟悉这部分API特征是一项艰难的学习过程。目前有关这方面的资料和书籍都少之又少,大所属介绍线程方面书籍还停留在java5之前的知识层面上。
当然新特征对做多线程程序没有必须的关系,在java5之前通用可以写出很优秀的多线程程序。只是代价不一样而已。
线程池的基本思想还是一种对象池的思想,开辟一块内存空间,里面存放了众多(未死亡)的线程,池中线程执行调度由池管理器来处理。当有线程任务时,从池中取一个,执行完成后线程对象归池,这样可以避免反复创建线程对象所带来的性能开销,节省了系统的资源。
在Java5之前,要实现一个线程池是相当有难度的,现在Java5为我们做好了一切,我们只需要按照提供的API来使用,即可享受线程池带来的极大便利。
Java5的线程池分好多种:具体的可以分为两类,固定尺寸的线程池、可变尺寸连接池。
在使用线程池之前,必须知道如何去创建一个线程池,在Java5中,需要了解的是java.util.concurrent.Executors类的API,这个类提供大量创建连接池的静态方法,是必须掌握的。
一、固定大小的线程池,newFixedThreadPool:
- package app.executors;
- import java.util.concurrent.Executors;
- import java.util.concurrent.ExecutorService;
- /**
- * Java线程:线程池
- *
- * @author 冯小卫
- */
- public class Test {
- public static void main(String[] args) {
- // 创建一个可重用固定线程数的线程池
- ExecutorService pool = Executors.newFixedThreadPool(5);
- // 创建线程
- Thread t1 = new MyThread();
- Thread t2 = new MyThread();
- Thread t3 = new MyThread();
- Thread t4 = new MyThread();
- Thread t5 = new MyThread();
- // 将线程放入池中进行执行
- pool.execute(t1);
- pool.execute(t2);
- pool.execute(t3);
- pool.execute(t4);
- pool.execute(t5);
- // 关闭线程池
- pool.shutdown();
- }
- }
- class MyThread extends Thread {
- @Override
- public void run() {
- System.out.println(Thread.currentThread().getName() + "正在执行。。。");
- }
- }
输出结果:
- pool-1-thread-1正在执行。。。
- pool-1-thread-3正在执行。。。
- pool-1-thread-4正在执行。。。
- pool-1-thread-2正在执行。。。
- pool-1-thread-5正在执行。。。
改变ExecutorService pool = Executors.newFixedThreadPool(5)中的参数:ExecutorService pool = Executors.newFixedThreadPool(2),输出结果是:
- pool-1-thread-1正在执行。。。
- pool-1-thread-1正在执行。。。
- pool-1-thread-2正在执行。。。
- pool-1-thread-1正在执行。。。
- pool-1-thread-2正在执行。。。
从以上结果可以看出,newFixedThreadPool的参数指定了可以运行的线程的最大数目,超过这个数目的线程加进去以后,不会运行。其次,加入线程池的线程属于托管状态,线程的运行不受加入顺序的影响。
二、单任务线程池,newSingleThreadExecutor:
仅仅是把上述代码中的ExecutorService pool = Executors.newFixedThreadPool(2)改为ExecutorService pool = Executors.newSingleThreadExecutor();
输出结果:
- pool-1-thread-1正在执行。。。
- pool-1-thread-1正在执行。。。
- pool-1-thread-1正在执行。。。
- pool-1-thread-1正在执行。。。
- pool-1-thread-1正在执行。。。
可以看出,每次调用execute方法,其实最后都是调用了thread-1的run方法。
三、可变尺寸的线程池,newCachedThreadPool:
与上面的类似,只是改动下pool的创建方式:ExecutorService pool = Executors.newCachedThreadPool();
输出:
- pool-1-thread-1正在执行。。。
- pool-1-thread-2正在执行。。。
- pool-1-thread-4正在执行。。。
- pool-1-thread-3正在执行。。。
- pool-1-thread-5正在执行。。。
这种方式的特点是:可根据需要创建新线程的线程池,但是在以前构造的线程可用时将重用它们。
四、延迟连接池,newScheduledThreadPool:
- package app.executors;
- import java.util.concurrent.Executors;
- import java.util.concurrent.ScheduledExecutorService;
- import java.util.concurrent.TimeUnit;
- /**
- * Java线程:线程池
- *
- * @author 冯小卫
- */
- public class Test {
- public static void main(String[] args) {
- // 创建一个线程池,它可安排在给定延迟后运行命令或者定期地执行。
- ScheduledExecutorService pool = Executors.newScheduledThreadPool(2);
- // 创建实现了Runnable接口对象,Thread对象当然也实现了Runnable接口
- Thread t1 = new MyThread();
- Thread t2 = new MyThread();
- Thread t3 = new MyThread();
- // 将线程放入池中进行执行
- pool.execute(t1);
- // 使用延迟执行风格的方法
- pool.schedule(t2, 1000, TimeUnit.MILLISECONDS);
- pool.schedule(t3, 10, TimeUnit.MILLISECONDS);
- // 关闭线程池
- pool.shutdown();
- }
- }
- class MyThread extends Thread {
- @Override
- public void run() {
- System.out.println(Thread.currentThread().getName() + "正在执行。。。");
- }
- }
读者可以尝试改变Executors.newScheduledThreadPool(2)的参数来得到更多的体验,当然,让
- @Override
- public void run() {
- System.out.println(Thread.currentThread().getName() + "正在执行。。。");
- }
变成一个无限循环,你可以得到更多的关于pool.shutdown()的用法。
五:单任务延迟连接池(和上面类似,就不写了)。当然我们也可以自定义线程池,这里就不写了,累啊……
Java Executors(线程池)相关推荐
- Java Executor源码解析(7)—Executors线程池工厂以及四大内置线程池
详细介绍了Executors线程池工具类的使用,以及四大内置线程池. 系列文章: Java Executor源码解析(1)-Executor执行框架的概述 Java Executor源码解析(2)-T ...
- Executors线程池关闭时间计算
Executors线程池关闭时间计算 学习了:http://blog.csdn.net/wo541075754/article/details/51564359 https://www.cnblogs ...
- Java并发—线程池ThreadPoolExecutor基本总结
原文作者:Matrix海子 原文地址:Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线 ...
- Java中线程池,你真的会用吗
转载自 Java中线程池,你真的会用吗 在<深入源码分析Java线程池的实现原理>这篇文章中,我们介绍过了Java中线程池的常见用法以及基本原理. 在文中有这样一段描述: 可以通过Ex ...
- 自定义java线程池_我的Java自定义线程池执行器
自定义java线程池 ThreadPoolExecutor是Java并发api添加的一项功能,可以有效地维护和重用线程,因此我们的程序不必担心创建和销毁线程,也不必关注核心功能. 我创建了一个自定义线 ...
- 我的Java自定义线程池执行器
ThreadPoolExecutor是Java并发api添加的一项功能,可以有效地维护和重用线程,因此我们的程序不必担心创建和销毁线程,而将精力放在核心功能上. 我创建了一个自定义线程池执行程序,以更 ...
- java中线程池的几种实现方式
1.线程池简介: 多线程技术主要解决处理器单元内多个线程执行的问题,它可以显著减少处理器单元的闲置时间,增加处理器单元的吞吐能力. 假设一个服务器完成一项任务所需时间为:T1 ...
- Java中线程池,你真的会用吗?
在<深入源码分析Java线程池的实现原理>这篇文章中,我们介绍过了Java中线程池的常见用法以及基本原理. 在文中有这样一段描述: 可以通过Executors静态工厂构建线程池,但一般不建 ...
- java异步线程池同时请求多个接口数据
java异步线程池同时请求多个接口数据 一.适合的使用场景 复杂的网页爬虫,如要同时请求多个不同网页的数据,并且需要执行不同的数据处理,这个是非常合适的,执行线程传递的参数到最后callback是会附 ...
最新文章
- 2014中国软件开发者调查(一):Java最受欢迎 第二语言JS使用比例最高
- POJ_1195 Mobile phones 【二维树状数组】
- Android之集成微信登录
- Git之深入解析如何交互式暂存
- [译]关于NODE_ENV,哪些你应该了解
- Linux平台-小型企业DHCP服务器的搭建
- Repeater控件的
- matlab更改安全密钥,Linux下设置安全密钥登录
- 在html css中加粗显示,HTML和CSS实现字体加粗的方法有哪些
- 7. 重磅硬核 | 一文聊透对象在JVM中的内存布局,以及内存对齐和压缩指针的原理及应用
- ubantu查看设备序列号
- WIN7开机后网络连接启动慢的手动解决方法
- 电商环境下中小企业客户关系管理系统设计
- android CMWAP, CMNET有何区别
- 手动删除EMCC13C的 Repository Database
- RTSP协议学习笔记
- MP1584EN降压型转换器学习
- EaselJS简明教程2-动画
- 数据采集---自制上位机界面接收单片机uart数据
- 【MySQL】聚合函数详解
热门文章
- 怎样删去csv中重复行_4个锦囊,祝你快速删去Excel中的重复数据
- android显示绘图动画,Android自定义View绘图实现渐隐动画
- python和rpa_什么是RPA
- 无线打印 airprint 服务器,如何让 Windows 的共享打印机支持 AirPrint
- java usbkey数字证书_Java创建数字证书
- windows和ubuntu双系统设置开机默认系统
- 工业以太网交换机在实际应用中的优势
- [渝粤教育] 西安工业大学 园中画境 中国古典园林造园艺术 参考 资料
- 【渝粤教育】电大中专新媒体营销实务 (11)作业 题库
- excel转las文件_这3种Word、Excel格式不变的互转方法,实在太好用了