From eb8bf0b3ea77effa8b936aa7cb82a5c3cbb14e94 Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Fri, 12 Dec 2014 18:15:46 +0000 Subject: [PATCH] updated tests --- .../net/openhft/chronicle/map/StatelessClientTest.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java b/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java index 0e9338fec..86df1ba3d 100644 --- a/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java +++ b/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java @@ -579,7 +579,6 @@ public class StatelessClientTest { for (int i = 0; i < count; i++) { - final int j = i; executorService.submit(new Runnable() { @Override @@ -590,7 +589,7 @@ public class StatelessClientTest { latch.countDown(); } catch (Error | Exception e) { LOG.error("", e); - executorService.shutdown(); + //executorService.shutdown(); } } @@ -624,7 +623,7 @@ public class StatelessClientTest { } catch (Error | Exception e) { e.printStackTrace(); LOG.error("", e); - executorService.shutdown(); + // executorService.shutdown(); } } }); @@ -632,7 +631,7 @@ public class StatelessClientTest { } - latch.await(10, TimeUnit.SECONDS); + latch.await(20, TimeUnit.SECONDS); System.out.println("" + count + " messages took " + TimeUnit.MILLISECONDS.toSeconds(System .currentTimeMillis() - startTime) + " seconds, using " + nThreads + "" +