线程池是什么？Java四种线程池的使用介绍

使用线程池的好处有很多，比如节省系统资源的开销，节省创建和销毁线程的时间等，当我们需要处理的任务较多时，就可以使用线程池，可能还有很多用户不知道Java线程池如何使用？下面小编给大家分享Java四种线程池的使用方法。

　　线程池介绍：

　　线程池是一种多线程处理形式，处理过程中将任务添加到队列，然后在创建线程后自动启动这些任务。线程池线程都是后台线程。每个线程都使用默认的堆栈大小，以默认的优先级运行，并处于多线程单元中。如果某个线程在托管代码中空闲（如正在等待某个事件），则线程池将插入另一个辅助线程来使所有处理器保持繁忙。如果所有线程池线程都始终保持繁忙，但队列中包含挂起的工作，则线程池将在一段时间后创建另一个辅助线程但线程的数目永远不会超过最大值。超过最大值的线程可以排队，但他们要等到其他线程完成后才启动。

　　Java四种线程池的使用：

　　Java通过Executors提供四种线程池，分别为：

　　newCachedThreadPool创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。

　　newFixedThreadPool 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。

　　newScheduledThreadPool 创建一个定长线程池，支持定时及周期性任务执行。

　　newSingleThreadExecutor 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序（FIFO， LIFO， 优先级）执行。

　　（1） newCachedThreadPool

　　创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。示例代码如下：

  1. 01package test;
  2. 02import java.util.concurrent.ExecutorService;
  3. 03import java.util.concurrent.Executors;
  4. 04public class ThreadPoolExecutorTest {
  5. 05public static void main(String[] args) {
  6. 06ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
  7. 07for (int i = 0; i < 10; i++) {
  8. 08final int index = i;
  9. 09try {
  10. 10Thread.sleep(index * 1000);
  11. 11} catch (InterruptedException e) {
  12. 12e.printStackTrace();
  13. 13}
  14. 14cachedThreadPool.execute(new Runnable() {
  15. 15public void run() {
  16. 16System.out.println(index);
  17. 17}
  18. 18});
  19. 19}
  20. 20}
  21. 21}

复制代码

　　线程池为无限大，当执行第二个任务时第一个任务已经完成，会复用执行第一个任务的线程，而不用每次新建线程。

　　（2） newFixedThreadPool

　　创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。示例代码如下：

  1. 01package test;
  2. 02import java.util.concurrent.ExecutorService;
  3. 03import java.util.concurrent.Executors;
  4. 04public class ThreadPoolExecutorTest {
  5. 05public static void main(String[] args) {
  6. 06ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);
  7. 07for (int i = 0; i < 10; i++) {
  8. 08final int index = i;
  9. 09fixedThreadPool.execute(new Runnable() {
  10. 10public void run() {
  11. 11try {
  12. 12System.out.println(index);
  13. 13Thread.sleep(2000);
  14. 14} catch (InterruptedException e) {
  15. 15e.printStackTrace();
  16. 16}
  17. 17}
  18. 18});
  19. 19}
  20. 20}
  21. 21}

复制代码

　　因为线程池大小为3，每个任务输出index后sleep 2秒，所以每两秒打印3个数字。

　　定长线程池的大小最好根据系统资源进行设置。如Runtime.getRuntime（）.availableProcessors（）

　　（3） newScheduledThreadPool

　　创建一个定长线程池，支持定时及周期性任务执行。延迟执行示例代码如下：

  1. 01package test;
  2. 02import java.util.concurrent.Executors;
  3. 03import java.util.concurrent.ScheduledExecutorService;
  4. 04import java.util.concurrent.TimeUnit;
  5. 05public class ThreadPoolExecutorTest {
  6. 06public static void main(String[] args) {
  7. 07ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
  8. 08scheduledThreadPool.schedule(new Runnable() {
  9. 09public void run() {
  10. 10System.out.println("delay 3 seconds");
  11. 11}
  12. 12}, 3, TimeUnit.SECONDS);
  13. 13}
  14. 14}

复制代码

　　表示延迟3秒执行。

　　定期执行示例代码如下：

  1. 01package test;
  2. 02import java.util.concurrent.Executors;
  3. 03import java.util.concurrent.ScheduledExecutorService;
  4. 04import java.util.concurrent.TimeUnit;
  5. 05public class ThreadPoolExecutorTest {
  6. 06public static void main(String[] args) {
  7. 07ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
  8. 08scheduledThreadPool.scheduleAtFixedRate(new Runnable() {
  9. 09public void run() {
  10. 10System.out.println("delay 1 seconds, and excute every 3 seconds");
  11. 11}
  12. 12}, 1, 3, TimeUnit.SECONDS);
  13. 13}
  14. 14}

复制代码

　　表示延迟1秒后每3秒执行一次。

　　（4） newSingleThreadExecutor

　　创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序（FIFO， LIFO， 优先级）执行。示例代码如下：

  1. 01package test;
  2. 02import java.util.concurrent.ExecutorService;
  3. 03import java.util.concurrent.Executors;
  4. 04public class ThreadPoolExecutorTest {
  5. 05public static void main(String[] args) {
  6. 06ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
  7. 07for (int i = 0; i < 10; i++) {
  8. 08final int index = i;
  9. 09singleThreadExecutor.execute(new Runnable() {
  10. 10public void run() {
  11. 11try {
  12. 12System.out.println(index);
  13. 13Thread.sleep(2000);
  14. 14} catch (InterruptedException e) {
  15. 15e.printStackTrace();
  16. 16}
  17. 17}
  18. 18});
  19. 19}
  20. 20}
  21. 21}

复制代码

　　结果依次输出，相当于顺序执行各个任务。

　　你可以使用JDK自带的监控工具来监控我们创建的线程数量，运行一个不终止的线程，创建指定量的线程，来观察：

　　工具目录：C:\Program Files\Java\jdk1.6.0_06\bin\jconsole.exe

　　运行程序做稍微修改：

  1. 01package test;
  2. 02import java.util.concurrent.ExecutorService;
  3. 03import java.util.concurrent.Executors;
  4. 04public class ThreadPoolExecutorTest {
  5. 05public static void main(String[] args) {
  6. 06ExecutorService singleThreadExecutor = Executors.newCachedThreadPool();
  7. 07for (int i = 0; i < 100; i++) {
  8. 08final int index = i;
  9. 09singleThreadExecutor.execute(new Runnable() {
  10. 10public void run() {
  11. 11try {
  12. 12while(true) {
  13. 13System.out.println(index);
  14. 14Thread.sleep(10 * 1000);
  15. 15}
  16. 16} catch (InterruptedException e) {
  17. 17e.printStackTrace();
  18. 18}
  19. 19}
  20. 20});
  21. 21try {
  22. 22Thread.sleep(500);
  23. 23} catch (InterruptedException e) {
  24. 24e.printStackTrace();
  25. 25}
  26. 26}
  27. 27}
  28. 28}

复制代码

　　效果如下：

　　选择我们运行的程序：

监控运行状态

　　关于Java四种线程池的使用技巧就给大家分享到这里了，正所谓工欲善其事，必先利其器，我们掌握了诀窍，处理事情才能事倍功半，希望可以帮助到大家。

如有不足之处请谅解：写下你宝贵的留言，我会及时改正

----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

伟大人nice

E-mail ：[email protected]

QQ ：602091999

Cell-phone number ：15800666248

http://www.cnblogs.com/lsw9/

　　欢迎骚扰　　

如有不足之处请谅解：写下你宝贵的留言，我会及时改正

----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

伟大人nice

E-mail ：[email protected]

QQ ：602091999

Cell-phone number ：15800666248

http://www.cnblogs.com/lsw9/

　　欢迎骚扰　　

原文地址：https://www.cnblogs.com/lsw9/p/9066528.html

时间： 2024-10-13 10:49:20

线程池是什么？Java四种线程池的使用介绍的相关文章

Java四种线程池newCachedThreadPool,newFixedThreadPool,newScheduledThreadPool,newSingleThreadExecutor

介绍new Thread的弊端及Java四种线程池的使用,对Android同样适用.本文是基础篇,后面会分享下线程池一些高级功能. 1.new Thread的弊端 执行一个异步任务你还只是如下new Thread吗? Java new Thread(new Runnable() { @Override public void run() { // TODO Auto-generated method stub } }).start(); 1 2 3 4 5 6 7 new Thread(new

Java四种线程池

Java四种线程池newCachedThreadPool,newFixedThreadPool,newScheduledThreadPool,newSingleThreadExecutor 时间:2015-10-20 22:37:40      阅读:8762      评论:0      收藏:0      [点我收藏+] 介绍new Thread的弊端及Java四种线程池的使用,对Android同样适用.本文是基础篇,后面会分享下线程池一些高级功能. 1.new Thread的弊端执行一个异

Java 四种线程池newCachedThreadPool,newFixedThreadPool,newScheduledThreadPool,newSingleThreadExecutor

原文:http://www.cnblogs.com/zhujiabin/p/5404771.html 介绍new Thread的弊端及Java四种线程池的使用,对Android同样适用.本文是基础篇,后面会分享下线程池一些高级功能. 1.new Thread的弊端执行一个异步任务你还只是如下new Thread吗? new Thread(new Runnable() { @Override public void run() { // TODO Auto-generated method stu

JUC-12.1.1-线程池中七大参数 四种线程池 五大状态

 ---------------->七大参数 在java中 ThreadPoolExecutor 是线程池类,这也是我们通常所说的线程池      下图是ThreadPoolExecutor构造方法 最后一个是全参数构造   里面有七大参数  corePoolSize 核心线程数量    maximumPoolSize  最大线程数     默认策略是超出会抛出异常 keepAliveTime  线程空闲后存活时间    TimeUnit  时间单位  和keepAliveTime配合使用  

Java四种线程池的使用

Java通过Executors提供四种线程池,分别为:newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程.newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待.newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行.newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有

JAVA四种线程池实例

1.new Thread的弊端 执行一个异步任务你还只是如下new Thread吗? Java 1 2 3 4 5 6 7 new Thread(new Runnable() { @Override public void run() { // TODO Auto-generated method stub } }).start(); 那你就out太多了,new Thread的弊端如下: a. 每次new Thread新建对象性能差. b. 线程缺乏统一管理,可能无限制新建线程,相互之间竞争,及

Java四种线程池的学习与总结

在Java开发中,有时遇到多线程的开发时,直接使用Thread操作,对程序的性能和维护上都是一个问题,使用Java提供的线程池来操作可以很好的解决问题. 一.new Thread的弊端 执行一个异步任务你还只是如下new Thread吗? new Thread(new Runnable(){ @Override public void run(){ //TODO Auto-generatedmethod stub } } ).start(); 那你就out太多了,new Thread的弊端如下:

Java线程池原理及四种线程池的使用

 一.线程池简介: 多线程技术主要解决处理器单元内多个线程执行的问题,它可以显著减少处理器单元的闲置时间,增加处理器单元的吞吐能力. 假设一个服务器完成一项任务所需时间为:T1 创建线程时间,T2 在线程中执行任务的时间,T3 销毁线程时间. 如果:T1 + T3 远大于 T2,则可以采用线程池,以提高服务器性能. 一个线程池包括以下四个基本组成部分: 1.线程池管理器(ThreadPool):用于创建并管理线程池,包括 创建线程池,销毁线程池,添加新任务: 2.工作线程(PoolWorke

Java ExecutorService四种线程池的简单使用

我们都知道创建一个线程可以继承Thread类或者实现Runnable接口,实际Thread类就是实现了Runnable接口. 到今天才明白后端线程的作用:我们可以开启线程去执行一些比较耗时的操作,类似于前台的ajax异步操作,比如说用户上传一个大的文件,我们可以获取到文件之后开启一个线程去操作该文件,但是可以提前将结果返回去,如果同步处理有可能太耗时,影响系统可用性. 1.new Thread的弊端 原生的开启线程执行异步任务的方式: new Thread(new Runnable() { @O