模拟并发的 4 种方式,还有谁不会??(2)

简介: 模拟并发的 4 种方式,还有谁不会??(2)

三、并发模拟工具JMeter


JMeter也是一款性能测试工具,是图形化的。下载地址:传送门 http://jmeter.apache.org/


25.png


需要 Java8+ 的环境


26.png


解压到你觉得合适的目录下(注意最好是英文路径),进入它的 bin 目录下 启动 jmeter.bat 即可。


image.png


使用很简单,首先在测试计划部分新建一个线程组


28.png29.png30.png


设置好基础信息后添加HTTP请求(基本信息设置好没有OK哈,直接添加HTTP请求)


31.png


填写HTTP请求相关的内容


32.png


之后还要添加监听器,这里选择是图形结果


33.png


再添加一个查看结果树吧


34.png


在运行之前打开log Viewer


35.png


下面开始运行:


36.png


执行成功,来感受一下结果:


37.png


点进去


38.png


查看结果树


39.png


四、代码模拟


这里需要用到一个类,就是 CountDownLatch。CountDownLatch 是一个计数器闭锁,通过它可以完成类似于阻塞当前线程的功能,即:一个线程或多个线程一直等待,直到其他线程执行的操作完成。


更多多线程教程可以参考:https://www.javastack.cn/categories/Java/


CountDownLatch 用一个给定的计数器来初始化,该计数器的操作是原子操作,即同时只能有一个线程去操作该计数器。调用该类await方法的线程会一直处于阻塞状态,直到其他线程调用 countDown 方法使当前计数器的值变为零,每次调用 countDown 计数器的值减1。


当计数器值减至零时,所有因调用await()方法而处于等待状态的线程就会继续往下执行。这种现象只会出现一次,因为计数器不能被重置。下图和它的方法可以体现出来:


40.png


CountDownLatch类只提供了一个构造器:


public CountDownLatch(int count) { };

然后下面这 3 个方法是 CountDownLatch 类中最重要的方法(上图能够反映出来)


public void await() throws InterruptedException { };
public boolean await(long timeout, TimeUnit unit) throws InterruptedException { };
public void countDown() { };


下面还需要看一个类 Semaphore


Semaphore 与 CountDownLatch 相似,不同的地方在于 Semaphore 的值被获取到后是可以释放的,并不像 CountDownLatch 那样一直减到底。


它也被更多地用来限制流量,类似阀门的 功能。如果限定某些资源最多有N个线程可以访问,那么超过N个主不允许再有线程来访问,同时当现有线程结束后,就会释放,然后允许新的线程进来。有点类似于锁的lock与 unlock过程。相对来说他也有两个主要的方法:


用于获取权限的acquire(),其底层实现与CountDownLatch.countdown()类似;用于释放权限的release(),其底层实现与acquire()是一个互逆的过程。


通过这两个类可以进行并发的模拟:


测试一下:


import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.*;
@Slf4j
public class CuncurrencyTest {
    public static int clientTotal = 5000;
    public static int threadTotal = 200;
    public static int count = 0;
    public static void main(String[] args) throws InterruptedException {
        ExecutorService executorService = Executors.newCachedThreadPool();
        final Semaphore semaphore = new Semaphore(threadTotal);
        final CountDownLatch countDownLatch = new CountDownLatch(clientTotal);
        for (int i = 0; i < clientTotal; i++) {
            executorService.execute(() -> {
                try {
                    semaphore.acquire();
                    add();
                    semaphore.release();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    log.error("exception",e);
                }
                countDownLatch.countDown();
            });
        }
        countDownLatch.await();
        executorService.shutdown();
        log.info("count:{}",count);
    }
    private static void  add() {
        count++;
    }
}


因为 count 不是线程安全的,且没有作防护措施,结果是错的


41.png


上面是对代码的并发模拟的简单形式,值得注意的是,这里提到的两个类不是专门做并发模拟,它们的用途很广泛,等之后更新Java网络编程的东西的时候,还会详细介绍它们。


相关文章
|
7月前
|
Web App开发 JSON 监控
模拟一次超过 5 万的并发用户
模拟一次超过 5 万的并发用户
55 0
|
5月前
|
机器学习/深度学习 Java 数据挖掘
线程操纵术之更优雅的并行策略问题之并发和并行有区别问题如何解决
线程操纵术之更优雅的并行策略问题之并发和并行有区别问题如何解决
|
7月前
|
监控 测试技术 Apache
如何模拟100个并发用户进行压力测试?
通过以上步骤,你可以使用JMeter对应用程序进行压力测试,评估其性能表现。
715 0
|
7月前
|
存储 前端开发 JavaScript
前端面试:如何实现并发请求数量控制?
前端面试:如何实现并发请求数量控制?
252 0
|
7月前
|
存储 前端开发
【源码共读】大并发量如何控制并发数
【源码共读】大并发量如何控制并发数
116 0
|
监控 Java Linux
模拟并发的 4 种方式,还有谁不会??(1)
模拟并发的 4 种方式,还有谁不会??(1)
312 0
模拟并发的 4 种方式,还有谁不会??(1)
|
存储 小程序 C++
c++多线程,模拟洗衣房
c++多线程,模拟洗衣房
c++多线程,模拟洗衣房
|
Java 调度
并发的本质是什么?
并发的本质是什么?
233 0
并发的本质是什么?
|
Java
【高并发】从源码角度深度解析线程池是如何实现优雅退出的
在【精通高并发系列】中,我们从源码角度深度分析了线程池中那些重要的接口和抽象类、深度解析了线程池是如何创建的,ThreadPoolExecutor类有哪些属性和内部类,以及它们对线程池的重要作用。深度分析了线程池的整体核心流程,以及如何拆解Worker线程的执行代码,深度解析Worker线程的执行流程。
337 0
【高并发】从源码角度深度解析线程池是如何实现优雅退出的
|
缓存 Java
【高并发】从源码角度分析创建线程池究竟有哪些方式
在Java的高并发领域,线程池一直是一个绕不开的话题。有些童鞋一直在使用线程池,但是,对于如何创建线程池仅仅停留在使用Executors工具类的方式,那么,创建线程池究竟存在哪几种方式呢?就让我们一起从创建线程池的源码来深入分析究竟有哪些方式可以创建线程池。
197 0
【高并发】从源码角度分析创建线程池究竟有哪些方式