前言

本篇博客中使用线程池改造该示例并进行分析 ;

一、线程池示例

创建 101010 万线程 , 需要 109921099210992 ms ; 使用线程池启动 101010 万线程 , 仅需要 262626 ms ;

线程池的效率比线程高几个数量级 ;

线程池示例 :

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class Main {/*** 线程中对该值进行累加操作*/private static int count = 0;public static void main(String[] args) throws InterruptedException {// 记录程序开始执行时间long startTime = System.currentTimeMillis();// 线程池ExecutorService executorService = Executors.newSingleThreadExecutor();// 每次线程执行完毕, 计数 -1 , 当计数减到 0 之后, 才能解除阻塞CountDownLatch countDownLatch = new CountDownLatch(100000);// 创建 10 万个线程, 开启线程后, 向集合中添加一个元素for (int i = 0; i < 100000; i ++) {executorService.execute(new Runnable() {@Overridepublic void run() {count ++;// 计数 -1countDownLatch.countDown();}});}// 阻塞等待计数 -1, 直到 10000 个线程执行完毕//  使用这种方式确定所有线程执行完毕countDownLatch.await();// 执行完毕后, 停掉线程池, 否则程序不会退出executorService.shutdown();// 记录程序执行结束时间long endTime = System.currentTimeMillis();// 打印消耗的时间System.out.println("耗时 : " + ( endTime - startTime ) + " ms , 最终 count = " + count);}
}

执行结果 : 原来使用线程需要 109921099210992 ms 时间 , 使用线程池后 , 仅需要 262626 ms , 这效率提升了好几个数量级 ;

等待线程执行结束 , 直接调用 Thread.join() 方法 , 等待线程池结束 , 借助 CountDownLatch 通过线程计数来确定线程是否执行完毕 ;

调用 ExecutorService executorService = Executors.newSingleThreadExecutor() 创建线程池 , 创建的是 FinalizableDelegatedExecutorService 线程池 ;

    public static ExecutorService newSingleThreadExecutor() {return new FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1, 1,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>()));}

二、newCachedThreadPool 线程池示例

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class Main {public static void main(String[] args) {ExecutorService executorService1 = Executors.newCachedThreadPool();for (int i = 0; i < 100; i ++) {executorService1.execute(new Task(i));}}static class Task implements Runnable {/*** 记录线程的索引 0 ~ 99*/private int i = 0;public Task(int i) {this.i = i;}@Overridepublic void run() {System.out.println("线程 ID : " + Thread.currentThread().getName() + " , 线程索引 : " + i);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}
}

执行结果 : 该线程池中创建了 100100100 个线程 , 执行 100100100 个任务 ;

三、newFixedThreadPool 线程池示例

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class Main {public static void main(String[] args) {ExecutorService executorService2 = Executors.newFixedThreadPool(10);for (int i = 0; i < 100; i ++) {executorService2.execute(new Task(i));}}static class Task implements Runnable {/*** 记录线程的索引 0 ~ 99*/private int i = 0;public Task(int i) {this.i = i;}@Overridepublic void run() {System.out.println("线程 ID : " + Thread.currentThread().getName() + " , 线程索引 : " + i);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}
}

执行结果 : 该线程池中创建了 101010 个线程 , 执行 100100100 个任务 ;

三、newSingleThreadExecutor 线程池示例

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class Main {public static void main(String[] args) {ExecutorService executorService3 = Executors.newSingleThreadExecutor();for (int i = 0; i < 100; i ++) {executorService3.execute(new Task(i));}}static class Task implements Runnable {/*** 记录线程的索引 0 ~ 99*/private int i = 0;public Task(int i) {this.i = i;}@Overridepublic void run() {System.out.println("线程 ID : " + Thread.currentThread().getName() + " , 线程索引 : " + i);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}
}

执行结果 : 该线程池中创建了 111 个线程 , 执行 100100100 个任务 ;

【Java 并发编程】线程池机制 ( 线程池示例 | newCachedThreadPool | newFixedThreadPool | newSingleThreadExecutor )相关推荐

Java 并发编程——Executor框架和线程池原理
Java 并发编程系列文章 Java 并发基础--线程安全性 Java 并发编程--Callable+Future+FutureTask java 并发编程--Thread 源码重新学习 java并发 ...
[Java并发编程（一）] 线程池 FixedThreadPool vs CachedThreadPool ...
[Java并发编程(一)] 线程池 FixedThreadPool vs CachedThreadPool ... 摘要介绍 Java 并发包里的几个主要 ExecutorService . 正文 ...
[Java并发编程（二）] 线程池 FixedThreadPool、CachedThreadPool、ForkJoinPool？为后台任务选择合适的 Java executors...
[Java并发编程(二)] 线程池 FixedThreadPool.CachedThreadPool.ForkJoinPool?为后台任务选择合适的 Java executors ... 摘要 Jav ...
《Java并发编程的艺术》——线程（笔记）
文章目录四.Java并发编程基础 4.1 线程简介 4.1.1 什么是线程 4.1.2 为什么要使用多线程 4.1.3 线程优先级 4.1.4 线程的状态 4.1.5 Daemon线程 4.2 启动 ...
Java并发编程|第二篇：线程生命周期
文章目录系列文章 1.线程的状态 2.线程生命周期 3.状态测试代码 4.线程终止 4.1 线程执行完成 4.2 interrupt 5.线程复位 5.1interrupted 5.2抛出异常 6. ...
Java并发编程之锁机制之LockSupport工具
关于文章涉及到的jdk源码,这里把最新的jdk源码分享给大家----->jdk源码前言在上篇文章<Java并发编程之锁机制之AQS(AbstractQueuedSynchronizer ...
Java并发编程(08)：Executor线程池框架
本文源码:GitHub·点这里 || GitEE·点这里一.Executor框架简介 1.基础简介 Executor系统中,将线程任务提交和任务执行进行了解耦的设计,Executor有各种功能强大的 ...
【Java 并发编程】多线程、线程同步、死锁、线程间通信（生产者消费者模型）、可重入锁、线程池
并发编程(Concurrent Programming) 进程(Process).线程(Thread).线程的串行多线程多线程的原理多线程的优缺点 Java并发编程默认线程开启新线程 `Ru ...
Java并发编程(8)——常见的线程安全问题
线程安全问题: 多个线程同时执行也能工作的代码就是线程安全的代码如果一段代码可以保证多个线程访问的时候正确操作共享数据,那么它是线程安全的. 具体说明: java并发线程实战(1) 线程安全和机制原 ...

【Java 并发编程】线程池机制 ( 线程池示例 | newCachedThreadPool | newFixedThreadPool | newSingleThreadExecutor )

文章目录

前言

一、线程池示例

二、newCachedThreadPool 线程池示例

三、newFixedThreadPool 线程池示例

三、newSingleThreadExecutor 线程池示例

【Java 并发编程】线程池机制 ( 线程池示例 | newCachedThreadPool | newFixedThreadPool | newSingleThreadExecutor )相关推荐

最新文章

热门文章