ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/SynchronousQueueTest.java
(Generate patch)

Comparing jsr166/src/test/tck/SynchronousQueueTest.java (file contents):
Revision 1.62 by jsr166, Fri Jun 22 00:04:58 2018 UTC vs.
Revision 1.63 by jsr166, Sun Aug 11 22:29:27 2019 UTC

# Line 139 | Line 139 | public class SynchronousQueueTest extend
139              }});
140  
141          await(pleaseInterrupt);
142 <        assertThreadBlocks(t, Thread.State.WAITING);
142 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.WAITING);
143          t.interrupt();
144          awaitTermination(t);
145          assertEquals(0, q.remainingCapacity());
# Line 180 | Line 180 | public class SynchronousQueueTest extend
180          catch (InterruptedException e) { threadUnexpectedException(e); }
181  
182          await(pleaseInterrupt);
183 <        assertThreadBlocks(t, Thread.State.WAITING);
183 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.WAITING);
184          t.interrupt();
185          awaitTermination(t);
186          assertEquals(0, q.remainingCapacity());
# Line 196 | Line 196 | public class SynchronousQueueTest extend
196          Thread t = newStartedThread(new CheckedRunnable() {
197              public void realRun() throws InterruptedException {
198                  long startTime = System.nanoTime();
199 +
200                  assertFalse(q.offer(new Object(), timeoutMillis(), MILLISECONDS));
201                  assertTrue(millisElapsedSince(startTime) >= timeoutMillis());
202  
203                  Thread.currentThread().interrupt();
204                  try {
205 <                    q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
205 >                    q.offer(new Object(), randomTimeout(), randomTimeUnit());
206                      shouldThrow();
207                  } catch (InterruptedException success) {}
208                  assertFalse(Thread.interrupted());
209  
210                  pleaseInterrupt.countDown();
211                  try {
212 <                    q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
212 >                    q.offer(new Object(), LONG_DELAY_MS, MILLISECONDS);
213                      shouldThrow();
214                  } catch (InterruptedException success) {}
215                  assertFalse(Thread.interrupted());
216 +
217 +                assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
218              }});
219  
220          await(pleaseInterrupt);
221 <        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
221 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.TIMED_WAITING);
222          t.interrupt();
223          awaitTermination(t);
224      }
# Line 274 | Line 277 | public class SynchronousQueueTest extend
277  
278                  Thread.currentThread().interrupt();
279                  try {
280 <                    q.poll(LONG_DELAY_MS, MILLISECONDS);
280 >                    q.poll(randomTimeout(), randomTimeUnit());
281                      shouldThrow();
282                  } catch (InterruptedException success) {}
283                  assertFalse(Thread.interrupted());
# Line 296 | Line 299 | public class SynchronousQueueTest extend
299          assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
300  
301          await(pleaseInterrupt);
302 <        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
302 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.TIMED_WAITING);
303          t.interrupt();
304          awaitTermination(t);
305      }

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines