diff --git a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java index bc960b093..c8e5aa824 100644 --- a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java @@ -89,7 +89,7 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clon private final ReentrantLock inBytesLock = new ReentrantLock(); - private final ReentrantLock outBytesLock = new ReentrantLock(true); + private final ReentrantLock outBytesLock = new ReentrantLock(); static enum EventId { diff --git a/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java b/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java index a021fea97..72b1ec661 100644 --- a/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java +++ b/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java @@ -524,7 +524,7 @@ public class StatelessClientTest { int nThreads = 2; final ExecutorService executorService = Executors.newFixedThreadPool(nThreads); - int count = 10000; + int count = 50000; final CountDownLatch latch = new CountDownLatch(count * 2); final AtomicInteger got = new AtomicInteger();