ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/SynchronousQueueTest.java

Comparing jsr166/src/test/tck/SynchronousQueueTest.java (file contents):
Revision 1.52 by jsr166, Sat Mar 18 20:42:20 2017 UTC vs.
Revision 1.56 by jsr166, Sun May 14 00:56:43 2017 UTC

#	Line 138 | Line 138 | public class SynchronousQueueTest extend
138		}});
139
140		await(pleaseInterrupt);
141	<	assertThreadStaysAlive(t);
141	>	assertThreadBlocks(t, Thread.State.WAITING);
142		t.interrupt();
143		awaitTermination(t);
144		assertEquals(0, q.remainingCapacity());
#	Line 172 | Line 172 | public class SynchronousQueueTest extend
172		catch (InterruptedException e) { threadUnexpectedException(e); }
173
174		await(pleaseInterrupt);
175	<	assertThreadStaysAlive(t);
175	>	assertThreadBlocks(t, Thread.State.WAITING);
176		t.interrupt();
177		awaitTermination(t);
178		assertEquals(0, q.remainingCapacity());
#	Line 196 | Line 196 | public class SynchronousQueueTest extend
196		q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
197		shouldThrow();
198		} catch (InterruptedException success) {}
199	+	assertFalse(Thread.interrupted());
200		}});
201
202		await(pleaseInterrupt);
203	<	assertThreadStaysAlive(t);
203	>	assertThreadBlocks(t, Thread.State.TIMED_WAITING);
204		t.interrupt();
205		awaitTermination(t);
206		}
#	Line 282 | Line 283 | public class SynchronousQueueTest extend
283		assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
284
285		await(pleaseInterrupt);
286	<	assertThreadStaysAlive(t);
286	>	assertThreadBlocks(t, Thread.State.TIMED_WAITING);
287		t.interrupt();
288		awaitTermination(t);
289		}

Diff Legend

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