--- a/test/jdk/java/util/Collection/RemoveMicroBenchmark.java Tue May 22 21:46:51 2018 -0700
+++ b/test/jdk/java/util/Collection/RemoveMicroBenchmark.java Tue May 22 21:50:45 2018 -0700
@@ -27,8 +27,10 @@
* @run main RemoveMicroBenchmark iterations=1 size=8 warmup=0
*/
+import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static java.util.stream.Collectors.toCollection;
+import java.lang.ref.ReferenceQueue;
import java.lang.ref.WeakReference;
import java.util.ArrayDeque;
import java.util.ArrayList;
@@ -112,17 +114,22 @@
/** No guarantees, but effective in practice. */
static void forceFullGc() {
- CountDownLatch finalizeDone = new CountDownLatch(1);
- WeakReference<?> ref = new WeakReference<Object>(new Object() {
- @SuppressWarnings("deprecation")
- protected void finalize() { finalizeDone.countDown(); }});
+ long timeoutMillis = 1000L;
+ CountDownLatch finalized = new CountDownLatch(1);
+ ReferenceQueue<Object> queue = new ReferenceQueue<>();
+ WeakReference<Object> ref = new WeakReference<>(
+ new Object() { protected void finalize() { finalized.countDown(); }},
+ queue);
try {
- for (int i = 0; i < 10; i++) {
+ for (int tries = 3; tries--> 0; ) {
System.gc();
- if (finalizeDone.await(1L, TimeUnit.SECONDS) && ref.get() == null) {
+ if (finalized.await(timeoutMillis, MILLISECONDS)
+ && queue.remove(timeoutMillis) != null
+ && ref.get() == null) {
System.runFinalization(); // try to pick up stragglers
return;
}
+ timeoutMillis *= 4;
}
} catch (InterruptedException unexpected) {
throw new AssertionError("unexpected InterruptedException");
@@ -504,6 +511,15 @@
Stream<Job> blockingQueueJobs(BlockingQueue<Integer> x) {
final String klazz = goodClassName(x.getClass());
return Stream.of(
+ new Job(klazz + " timed poll()") {
+ public void work() throws Throwable {
+ int[] sum = new int[1];
+ for (int i = 0; i < iterations; i++) {
+ sum[0] = 0;
+ x.addAll(elements);
+ for (Integer e; (e = x.poll(0L, TimeUnit.DAYS)) != null; )
+ sum[0] += e;
+ check.sum(sum[0]);}}},
new Job(klazz + " drainTo(sink)") {
public void work() throws Throwable {
ArrayList<Integer> sink = new ArrayList<>();