一、使用 CountDownLatch 模拟多线程并发（并行）

CountDownLatch 介绍：

countDownLatch是在java1.5被引入，跟它一起被引入的工具类还有CyclicBarrier、Semaphore、concurrentHashMap和BlockingQueue。
存在于java.util.cucurrent包下。

作用：

CountDownLatch典型用法：1、某一线程在开始运行前等待n个线程执行完毕。将CountDownLatch的计数器初始化为new CountDownLatch(n)，每当一个任务线程执行完毕，就将计数器减1 countdownLatch.countDown()，当计数器的值变为0时，在CountDownLatch上await()的线程就会被唤醒。一个典型应用场景就是启动一个服务时，主线程需要等待多个组件加载完毕，之后再继续执行。
CountDownLatch典型用法：2、实现多个线程开始执行任务的最大并行性。注意是并行性，不是并发，强调的是多个线程在某一时刻同时开始执行。类似于赛跑，将多个线程放到起点，等待发令枪响，然后同时开跑。做法是初始化一个共享的CountDownLatch(1)，将其计算器初始化为1，多个线程在开始执行任务前首先countdownlatch.await()，当主线程调用countDown()时，计数器变为0，多个线程同时被唤醒

实现：典型用法2：

public class InitService {private static final Logger log = LoggerFactory.getLogger(InitService.class);public static final int THREAD_NUM = 200;private static int mobile = 0;//    @Autowired
//    private ConcurrencyService concurrencyService;
//
//    @Autowired
//    private CommonMqService commonMqService;public static void generateMultiThread() {log.info("开始初始化线程数----> ");//TODO：计算器初始化为1CountDownLatch countDownLatch = new CountDownLatch(1);try {//TODO：使用线程池启动线程  并行量200ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().build();ExecutorService singleThreadPool = new ThreadPoolExecutor(200, 200,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<>(1024), namedThreadFactory, new AbortPolicy());//TODO：启动多个线程for (int i = 0; i < THREAD_NUM; i++) {singleThreadPool.execute(new RunThread(countDownLatch));}singleThreadPool.shutdown();} catch (Exception e) {e.printStackTrace();}finally {//TODO：线程等待变量减少 释放所有线程 同时跑countDownLatch.countDown();}}private static class RunThread implements Runnable {private final CountDownLatch startLatch;public RunThread(CountDownLatch startLatch) {this.startLatch = startLatch;}@Overridepublic void run() {try {//TODO: 线程等待 等待剩余所有线程准备完毕 一起执行startLatch.await();mobile += 1;System.out.println("手机号为"+mobile+"的线程"+Thread.currentThread().getName()+"已执行");     } catch (Exception e) {e.printStackTrace();}}}//测试public static void main(String[] args) {generateMultiThread();}
}

结果：

可以看到线程执行的顺序，并不是顺序执行，而且错乱执行，200个线程共同执行的结果。

Java 模拟多线程并发案例相关推荐

java 模拟多线程并发_Java中模拟同时并发请求
有时需要测试一下某个功能的并发性能,又不要想借助于其他工具,索性就自己的开发语言,来一个并发请求就最方便了. java中模拟并发请求,自然是很方便的,只要多开几个线程,发起请求就好了.但是,这种请求, ...
java基础-多线程应用案例展示
java基础-多线程应用案例展示作者:尹正杰版权声明:原创作品,谢绝转载!否则将追究法律责任. 一.两只熊,100只蜜蜂,蜜蜂每次生产的蜂蜜量是1,罐子的容量是30,熊在罐子的蜂蜜量达到20的时候 ...
Java接口多线程并发测试（一）
本文为作者原创,禁止转载,违者必究法律责任!!! 本文为作者原创,禁止转载,违者必究法律责任!!! Java接口多线程并发测试一,首先写一个接口post 请求代码: import org.apach ...
Java模拟实现并发
Java模拟实现并发 import org.springframework.beans.factory.annotation.Autowired; import org.springframework ...
java sqlite 多线程并发_C#_C#解决SQlite并发异常问题的方法(使用读写锁)，本文实例讲述了C#解决SQlite并 - phpStudy...
C#解决SQlite并发异常问题的方法(使用读写锁) 本文实例讲述了C#解决SQlite并发异常问题的方法.分享给大家供大家参考,具体如下: 使用C#访问sqlite时,常会遇到多线程并发导致SQLI ...
java sqlite 多线程并发_sqlite之多线程总结
12.android 多线程数据库读写分析与优化 11.多线程操作Sqlite? ==== 最新需要给软件做数据库读写方面的优化,之前无论读写,都是用一个 SQLiteOpenHelper.getWr ...
Linux网络编程基础及多线程并发案例
目录 1.ip:端口 TCP/IP协议 2.socket 头文件 sys/socket.h 3.字节序 4.ip地址转换函数 5.sockaddr和sockaddr_in 6.服务器端基本函数 b ...
java核心技术-多线程并发设计原理以及常见面试题
文章目录写在前面多线程回顾 Thread和Runnable 面试官:为什么我们在项目中推荐使用使用Runnable方法而不用继承Thread? 面试官:Callable为什么可以带返回值,你知道底 ...
java模拟多线程买票问题
多线程买票是java中的一个经典案例,其主要思想无非包括2点,synchronized和锁,两者中,前者实现同步,后者为同步的线程提供锁,从而实现多个线程共享同一份资源时候,能够同步进行; 经典的方式 ...

Java 模拟多线程并发案例

一、使用 CountDownLatch 模拟多线程并发（并行）

CountDownLatch 介绍：

作用：

Java 模拟多线程并发案例相关推荐

最新文章

热门文章