From 226589f773f03e39fbb8e2deed392c1fa76c3ab9 Mon Sep 17 00:00:00 2001 From: Eric Zhao Date: Wed, 6 Mar 2019 09:51:36 +0800 Subject: [PATCH] dashboard: update InMemoryMetricsRepositoryTest Signed-off-by: Eric Zhao --- .../repository/metric/InMemoryMetricsRepositoryTest.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/sentinel-dashboard/src/test/java/com/alibaba/csp/sentinel/dashboard/repository/metric/InMemoryMetricsRepositoryTest.java b/sentinel-dashboard/src/test/java/com/alibaba/csp/sentinel/dashboard/repository/metric/InMemoryMetricsRepositoryTest.java index 17f81970..c4052526 100644 --- a/sentinel-dashboard/src/test/java/com/alibaba/csp/sentinel/dashboard/repository/metric/InMemoryMetricsRepositoryTest.java +++ b/sentinel-dashboard/src/test/java/com/alibaba/csp/sentinel/dashboard/repository/metric/InMemoryMetricsRepositoryTest.java @@ -37,8 +37,6 @@ import static org.junit.Assert.*; */ public class InMemoryMetricsRepositoryTest { - private static final int AVAILABLE_CPU_PROCESSORS = Runtime.getRuntime().availableProcessors(); - private static final String DEFAULT_APP = "default"; private static final String DEFAULT_EXPIRE_APP = "default_expire_app"; private static final String DEFAULT_RESOURCE = "test"; @@ -51,7 +49,7 @@ public class InMemoryMetricsRepositoryTest { @Before public void setUp() throws Exception { inMemoryMetricsRepository = new InMemoryMetricsRepository(); - executorService = Executors.newFixedThreadPool(AVAILABLE_CPU_PROCESSORS); + executorService = Executors.newFixedThreadPool(8); } @After @@ -112,7 +110,7 @@ public class InMemoryMetricsRepositoryTest { List futures = Lists.newArrayList(); // concurrent query resources of app - final CyclicBarrier cyclicBarrier = new CyclicBarrier(AVAILABLE_CPU_PROCESSORS); + final CyclicBarrier cyclicBarrier = new CyclicBarrier(8); for (int j = 0; j < 10000; j++) { futures.add( CompletableFuture.runAsync(() -> {