Java基于CountDownLatch的并发测试工具

在并发测试中，可以测试单元测试，也可以测试服务运行。
抽象并发控制类AbstractConcurrentControl ：
使用步骤：
1.单元测试类继承此类；
2.重写concurrentCode方法，定义自己的并发代码；
3.重写encapsulatingData方法，定义数据的拼装，并在concurrentCode方法中调用；
4.重写blockingMainThread方法，定义主线程阻塞策略

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;/*** @author Yangzhen* @Description 1.单元测试类继承此类；*              2.重写concurrentCode方法，定义自己的并发代码；*              3.重写encapsulatingData方法，并在concurrentCode方法中调用，定义数据的拼装；*              4.重写blockingMainThread方法，定义主线程阻塞策略* @date 2018-12-26 10:06**/
public abstract class AbstractConcurrentControl {public AtomicLong longCounter = new AtomicLong(0);public AtomicInteger intCounter = new AtomicInteger(0);/*** 默认并发线程数为2000个，子类可重写*/private static final int DEFAULT_CONCURRENT_CONTROL = 2000;private CountDownLatch blockLatch;/*** 并发线程数量，默认2000*/private int concurrentThreadNum;private ThreadPoolExecutor threadPool;public AbstractConcurrentControl() {this(DEFAULT_CONCURRENT_CONTROL);}public AbstractConcurrentControl(int concurrentThreadNum) {this.concurrentThreadNum = concurrentThreadNum;blockLatch = new CountDownLatch(concurrentThreadNum);threadPool = new ThreadPoolExecutor(concurrentThreadNum, concurrentThreadNum, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());}/*** 并发执行线程** @Title: process* @date 2018年12月26日 上午11:19:20* @author yz*/public final void process() {for (int i = 0; i < concurrentThreadNum; i++) {threadPool.submit(new Runnable() {@Overridepublic void run() {try {blockLatch.await();concurrentCode();} catch (InterruptedException e) {e.printStackTrace();}}});// 最后一个线程时可以打个断点if (i == concurrentThreadNum - 1) {blockLatch.countDown();} else {blockLatch.countDown();}}blockingMainThread();}/*** 并发代码** @Title: concurrentCode* @date 2018年12月26日 下午2:05:25* @author yz*/protected abstract void concurrentCode();/*** 并发数据** @return* @Title: encapsulatingData* @date 2018年12月26日 下午2:06:14* @author yz*/protected <T> T encapsulatingData() {return null;}/*** 阻塞主线程，防止JVM关闭，不建议使用Xxx.class.wait，可以使用TimeUnit.SECONDS.sleep(200);* 如果使用TimeUnit.SECONDS.sleep(200)，要保证休眠时长足够跑完你的程序，否则会出现异常，因为JVM已经关闭，而测试的线程可能没有执行完成** @Title: blockingMainThread* @date 2018年12月26日 下午6:55:03* @author yz*/protected void blockingMainThread() {if (this.threadPool == null) {return;}this.threadPool.shutdown();while (!this.threadPool.isTerminated()) {try {TimeUnit.MILLISECONDS.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}}System.out.println("线程池关闭");}
}

单元测试案例：

public class RequestTest extends AbstractConcurrentControl {public RequestTest() {super(1);}private MyService myService = new MyService();/*** 单元测试，调用process方法*/@Testpublic void test() {process();}@Overridepublic void concurrentCode() {Data data = (Data) encapsulatingData();myService.process(data);}/*** 定义数据** @param <T>* @return*/@SuppressWarnings("unchecked")@Overridepublic <T> T encapsulatingData() {Data data = new Data();String name = "a";int i = intCounter.incrementAndGet();data.setId(i);data.setName(name + ":" + i);return (T) data;}
}public class Data {private Integer id;private String name;public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}
}public class MyService {public void process(Data data) {System.out.println(data.getId() + "-" + data.getName());}
}

Java基于CountDownLatch的并发测试工具相关推荐

并发测试工具_软件测试工程师都在用哪些测试工具？
工欲善其事,必先利其器,高效开展软件测试活动,除了测试工程师工作中认真敬业之外,还应有优秀的测试工具辅助其工作.测试工具能提高测试效率,辅助实现测试目标,提升个人的技能. 下面简单介绍一下目前业内常用 ...
soapui工具_基于开源的API测试工具！不再为web服务负载测试而发愁
通过一个可视化.拖拽式的界面,LoadUI允许您实时.交互式地创建.配置和重分配负载测试.在单一测试环境下,LoadUI提供完整的测试覆盖,支持所有标准的协议和技术.它功能强大,能从任意数量的本地和远 ...
apache并发测试工具ab为什么测不准
apache并发测试工具ab为什么测不准发表于2年前(2013-03-21 12:13) 阅读(1146) | 评论(1) 1人收藏此文章, 我要收藏赞0 3月21日深圳 OSC 源创会正在 ...
tsung压测mysql_高并发测试工具Tsung使用教程
tsung是erlang开发的一款开源的多协议分布式负载并发测试工具, 可用作HTTP.WebDAV.SOAP.PostgreSQL.MySQL.LDAP 和 Jabber/XMPP的服务器压力测试. ...
http-little-toy(一个go编写Http并发测试工具)
http-little-toy 一个简单的 http 并发测试工具. 仓库地址如果喜欢就star⭐️一下吧,让它沉睡在你的收藏库里. https://github.com/leihenshang/h ...
Windows并发测试工具
Apache安装目录cmd 用ab并发测试工具,请求10次,并发为5 ab -n 10 -c 5 http://www.ysbm.com/api.php/task/testBingfa
webbench windows_linux下的web并发测试工具汇总：ab, siege和webbench
原创:欢迎分享,转载请保留出处. 对于做云平台或写web服务组件的童鞋来说,并发测试是一道绕不过去的坎.jemeter也许是QA美美的最爱,但不太会是程序员男神的朱丽叶.对于十年程序猿的我来说,任何工 ...
go python php 压力测试_pyLot 基于python的压力测试工具
因为组内的产品是一个供上海甚至全球所有designer使用的网站,所以并发性很高,于是一直存在访问速度不佳的诟病.为了提高访问速度,就需要对该网站的性能进行测试.于是在网上查了并发性测试和自动化测试的 ...
html5 并发测试工具,超实用压力测试工具－ab工具
吞吐率(Requests per second) 概念:服务器并发处理能力的量化描述,单位是reqs/s,指的是某个并发用户数下单位时间内处理的请求数.某个并发用户数下单位时间内能处理的最大请求数,称 ...
JMeter——并发测试工具类安装及使用
关注微信公众号:CodingTechWork,一起学习进步. 引言在程序员开发完代码后,我们需要先自测,对于restful风格的代码,我们常常需要调用接口api进行测试,一般我们会在浏览器上直接 ...

Java基于CountDownLatch的并发测试工具

Java基于CountDownLatch的并发测试工具相关推荐

最新文章

热门文章