opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-10-31 02:57:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

[RIP-10] modify test case StatsItemSetTest's param (#1053)

Browse Source
This commit is contained in:
hdchen
2019-03-06 21:27:53 +08:00
committed by dinglei
parent 9cf0979761
commit 690a406ec1
1 changed files with 10 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/src/test/java/org/apache/rocketmq/common/stats/StatsItemSetTest.java
+10 -14
View File
@@ -36,23 +36,19 @@ public class StatsItemSetTest {
@Test
public void test_getAndCreateStatsItem_multiThread() throws InterruptedException {
for (int i = 0; i < 50; i++) {
assertEquals(20000L, test_unit().longValue());
}
assertEquals(20L, test_unit().longValue());
}
@Test
public void test_getAndCreateMomentStatsItem_multiThread() throws InterruptedException {
for (int i = 0; i < 50; i++) {
assertEquals(10, test_unit_moment().longValue());
}
assertEquals(10, test_unit_moment().longValue());
}
private AtomicLong test_unit() throws InterruptedException {
final StatsItemSet statsItemSet = new StatsItemSet("topicTest", scheduler, null);
executor = new ThreadPoolExecutor(100, 200, 10, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(10000), new ThreadFactoryImpl("testMultiThread"));
for (int i = 0; i < 10000; i++) {
executor = new ThreadPoolExecutor(10, 20, 10, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(100), new ThreadFactoryImpl("testMultiThread"));
for (int i = 0; i < 10; i++) {
executor.submit(new Runnable() {
@Override
public void run() {
@@ -61,7 +57,7 @@ public class StatsItemSetTest {
});
}
while (true) {
if (executor.getCompletedTaskCount() == 10000) {
if (executor.getCompletedTaskCount() == 10) {
break;
}
Thread.sleep(1000);
@@ -71,9 +67,9 @@ public class StatsItemSetTest {
private AtomicLong test_unit_moment() throws InterruptedException {
final MomentStatsItemSet statsItemSet = new MomentStatsItemSet("topicTest", scheduler, null);
executor = new ThreadPoolExecutor(100, 200, 10, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(10000), new ThreadFactoryImpl("testMultiThread"));
for (int i = 0; i < 10000; i++) {
executor = new ThreadPoolExecutor(10, 20, 10, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(100), new ThreadFactoryImpl("testMultiThread"));
for (int i = 0; i < 10; i++) {
executor.submit(new Runnable() {
@Override
public void run() {
@@ -82,7 +78,7 @@ public class StatsItemSetTest {
});
}
while (true) {
if (executor.getCompletedTaskCount() == 10000) {
if (executor.getCompletedTaskCount() == 10) {
break;
}
Thread.sleep(1000);