Tweaks to investigate Windows infinite loop and/or spurious wakeup.

pull/458/head
Brett Wooldridge 10 years ago
parent a0d20cb9de
commit ca0464d659

@ -156,8 +156,8 @@ public class ConcurrentBag<T extends IConcurrentBagEntry> implements AutoCloseab
addItemFuture = listener.addBagItem(); addItemFuture = listener.addBagItem();
} }
timeout = originTimeout - (System.nanoTime() - startScan); timeout = originTimeout - Math.abs(System.nanoTime() - startScan);
} while (timeout > 1000L && synchronizer.waitUntilSequenceExceeded(startSeq, timeout)); } while (timeout > 100_00L && synchronizer.waitUntilSequenceExceeded(startSeq, timeout));
return null; return null;
} }

@ -50,7 +50,7 @@ public interface Sequence
public static Sequence create() public static Sequence create()
{ {
try { try {
if (Sequence.class.getClassLoader().loadClass("java.util.concurrent.atomic.LongAdder") != null) { if (Sequence.class.getClassLoader().loadClass("java.util.concurrent.atomic.LongAdder") != null && !Boolean.getBoolean("com.zaxxer.hikari.useAtomicLongSequence")) {
return new Java8Sequence(); return new Java8Sequence();
} }
} }

Loading…
Cancel
Save