Java 线程池模拟用户并发请求接口代码示例

简介: Java 线程池模拟用户并发请求接口代码示例

1.应用场景:

日常开发人员,可能自己写完接口之后,对于一些重要的接口需要进行并发的控制,一旦出现并发导致系统正常业务,或者数据出现错误,那应该是我们最不想看到的结果。

这里可能有人会说,有专门的压测工具,但是压测是主要用来测试吞吐量的。

我这里主要是想验证程序的正常业务逻辑是否符合程序设计的预期业务逻辑。所以侧重点儿不一样,而且作为一个开发人员,想要自己测试自己的程序,我个人觉得自己编码测试,是最直接有效的方式。

2.模拟实现思路:

线程池并发请求:ThreadPoolExecutor
Jdk的计数器,控制并发请求开始时间点儿。

CountDownLatch :计数器的作用,大白话给大家讲解一下,类似于赛道上有多个运动员同时准备起跑时,那个发令枪的作用,枪一响起跑线上的运动员同时开跑。

3.代码示例

package com.xxx.test;
 
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
 
 
public class TestMultiUserReq {
     
    public static void main(String[] args) throws Exception {
        //线程池设置2000个核心线程数,最大5000
        ThreadPoolExecutor executor = new ThreadPoolExecutor(2000, 5000, 2, TimeUnit.MINUTES,
                new ArrayBlockingQueue<Runnable>(5000));
        //设置计数器,计数器的作用:类似于赛道上有多个运动员同时准备起跑时,那个发令枪的作用,枪一响起跑线上的运动员同时开跑
        CountDownLatch latch = new CountDownLatch(1);
        //模拟100个用户
        int userCount = 100;//同一时间请求的用户数量
        for (int i = 0; i < userCount; i++) {
            ClientUser analogUser = new ClientUser(latch);
            executor.execute(analogUser);
        }
        //计数器減一  所有线程释放 并发访问。
        latch.countDown();
        executor.shutdown();
    }
 
 
    static class ClientUser implements Runnable {
        CountDownLatch latch;
        public ClientUser(CountDownLatch latch) {
            this.latch = latch;
 
        }
        
        @Override
        public void run() {
            long starTime = 0;
            try {
                starTime = System.currentTimeMillis();
                latch.await();
                System.out.println("开始请求接口============");
                //这里写你请求的接口逻辑代码
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            long endTime = System.currentTimeMillis();
            Long t = endTime - starTime;
            System.out.println("耗时:"+t / 1000F + "秒");
        }
    }
}

感觉对您有帮助的话,帮小编点个免费的赞吧!

相关文章
|
1月前
|
Java 开发工具
【Azure Storage Account】Java Code访问Storage Account File Share的上传和下载代码示例
本文介绍如何使用Java通过azure-storage-file-share SDK实现Azure文件共享的上传下载。包含依赖引入、客户端创建及完整示例代码,助你快速集成Azure File Share功能。
337 4
|
1月前
|
Java 数据处理 API
为什么你的Java代码应该多用Stream?从循环到声明式的思维转变
为什么你的Java代码应该多用Stream?从循环到声明式的思维转变
234 115
|
1月前
|
安全 Java 编译器
为什么你的Java代码需要泛型?类型安全的艺术
为什么你的Java代码需要泛型?类型安全的艺术
172 98
|
1月前
|
Java 编译器 API
java最新版和java8的区别,用代码展示
java最新版和java8的区别,用代码展示
245 43
|
1月前
|
Java 大数据 Go
从混沌到秩序:Java共享内存模型如何通过显式约束驯服并发?
并发编程旨在混乱中建立秩序。本文对比Java共享内存模型与Golang消息传递模型,剖析显式同步与隐式因果的哲学差异,揭示happens-before等机制如何保障内存可见性与数据一致性,展现两大范式的深层分野。(238字)
63 4
|
1月前
|
缓存 安全 Java
如何理解Java中的并发?
Java并发指多任务交替执行,提升资源利用率与响应速度。通过线程实现,涉及线程安全、可见性、原子性等问题,需用synchronized、volatile、线程池及并发工具类解决,是高并发系统开发的关键基础。(238字)
198 4
|
6月前
|
机器学习/深度学习 消息中间件 存储
【高薪程序员必看】万字长文拆解Java并发编程!(9-2):并发工具-线程池
🌟 ​大家好,我是摘星!​ 🌟今天为大家带来的是并发编程中的强力并发工具-线程池,废话不多说让我们直接开始。
252 0
|
6月前
|
缓存 安全 Java
【高薪程序员必看】万字长文拆解Java并发编程!(3-1):并发共享问题的解决与分析
活锁:多个线程相互影响对方退出同步代码块的条件而导致线程一直运行的情况。例如,线程1的退出条件是count=5,而线程2和线程3在其代码块中不断地是count进行自增自减的操作,导致线程1永远运行。内存一致性问题:由于JIT即时编译器对缓存的优化和指令重排等造成的内存可见性和有序性问题,可以通过synchronized,volatile,并发集合类等机制来解决。这里的线程安全是指,多个线程调用它们同一个实例的方法时,是线程安全的,但仅仅能保证当前调用的方法是线程安全的,不同方法之间是线程不安全的。
133 0
|
6月前
|
Java 程序员
【高薪程序员必看】万字长文拆解Java并发编程!(3-2):并发共享问题的解决与分析
wait方法和notify方法都是Object类的方法:让当前获取锁的线程进入waiting状态,并进入waitlist队列:让当前获取锁的线程进入waiting状态,并进入waitlist队列,等待n秒后自动唤醒:在waitlist队列中挑一个线程唤醒:唤醒所有在waitlist队列中的线程它们都是之间协作的手段,只有拥有对象锁的线程才能调用这些方法,否则会出现IllegalMonitorStateException异常park方法和unpark方法是LockSupport类中的方法。
141 0
|
安全 Java 调度
解锁Java并发编程高阶技能:深入剖析无锁CAS机制、揭秘魔法类Unsafe、精通原子包Atomic,打造高效并发应用
【8月更文挑战第4天】在Java并发编程中,无锁编程以高性能和低延迟应对高并发挑战。核心在于无锁CAS(Compare-And-Swap)机制,它基于硬件支持,确保原子性更新;Unsafe类提供底层内存操作,实现CAS;原子包java.util.concurrent.atomic封装了CAS操作,简化并发编程。通过`AtomicInteger`示例,展现了线程安全的自增操作,突显了这些技术在构建高效并发程序中的关键作用。
204 1

热门文章

最新文章