--- jsr166/src/test/tck/BlockingQueueTest.java 2014/12/31 20:09:08 1.14 +++ jsr166/src/test/tck/BlockingQueueTest.java 2017/05/13 21:43:50 1.18 @@ -235,6 +235,8 @@ public abstract class BlockingQueueTest shouldThrow(); } catch (InterruptedException success) {} assertFalse(Thread.interrupted()); + + assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); }}); barrier.await(); @@ -265,7 +267,7 @@ public abstract class BlockingQueueTest }}); await(threadStarted); - assertThreadStaysAlive(t); + assertThreadBlocks(t, Thread.State.WAITING); t.interrupt(); awaitTermination(t); } @@ -306,7 +308,7 @@ public abstract class BlockingQueueTest }}); await(threadStarted); - assertThreadStaysAlive(t); + assertThreadBlocks(t, Thread.State.TIMED_WAITING); t.interrupt(); awaitTermination(t); } @@ -348,20 +350,20 @@ public abstract class BlockingQueueTest assertEquals((pass == 0), q.contains(elts[i])); assertEquals((pass == 0), q.remove(elts[i])); assertFalse(q.contains(elts[i])); - assertTrue(q.contains(elts[i-1])); + assertTrue(q.contains(elts[i - 1])); if (i < size - 1) - assertTrue(q.contains(elts[i+1])); + assertTrue(q.contains(elts[i + 1])); } } if (size > 0) assertTrue(q.contains(elts[0])); - for (int i = size-2; i >= 0; i -= 2) { + for (int i = size - 2; i >= 0; i -= 2) { assertTrue(q.contains(elts[i])); - assertFalse(q.contains(elts[i+1])); + assertFalse(q.contains(elts[i + 1])); assertTrue(q.remove(elts[i])); assertFalse(q.contains(elts[i])); - assertFalse(q.remove(elts[i+1])); - assertFalse(q.contains(elts[i+1])); + assertFalse(q.remove(elts[i + 1])); + assertFalse(q.contains(elts[i + 1])); } checkEmpty(q); }