ViewVC Help

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

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

Comparing jsr166/src/test/tck/PhaserTest.java (file contents):
Revision 1.45 by jsr166, Sat Feb 18 15:05:55 2017 UTC vs.
Revision 1.46 by jsr166, Sat May 13 23:05:02 2017 UTC

#	Line 523 | Line 523 | public class PhaserTest extends JSR166Te
523		}});
524
525		await(pleaseArrive);
526	<	waitForThreadToEnterWaitState(t);
526	>	assertThreadBlocks(t, Thread.State.WAITING);
527		assertEquals(0, phaser.arrive());
528		awaitTermination(t);
529
#	Line 551 | Line 551 | public class PhaserTest extends JSR166Te
551		}});
552
553		await(pleaseArrive);
554	<	waitForThreadToEnterWaitState(t);
554	>	assertThreadBlocks(t, Thread.State.WAITING);
555		t.interrupt();
556		assertEquals(0, phaser.arrive());
557		awaitTermination(t);
#	Line 580 | Line 580 | public class PhaserTest extends JSR166Te
580		}});
581
582		await(pleaseArrive);
583	<	waitForThreadToEnterWaitState(t);
583	>	assertThreadBlocks(t, Thread.State.WAITING);
584		Thread.currentThread().interrupt();
585		assertEquals(1, phaser.arriveAndAwaitAdvance());
586		assertTrue(Thread.interrupted());
#	Line 605 | Line 605 | public class PhaserTest extends JSR166Te
605		}});
606
607		await(pleaseInterrupt);
608	<	waitForThreadToEnterWaitState(t);
608	>	assertThreadBlocks(t, Thread.State.WAITING);
609		t.interrupt();
610		Thread.currentThread().interrupt();
611		assertEquals(1, phaser.arriveAndAwaitAdvance());
#	Line 780 | Line 780 | public class PhaserTest extends JSR166Te
780		assertEquals(THREADS, phaser.getArrivedParties());
781		assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
782		for (Thread thread : threads)
783	<	waitForThreadToEnterWaitState(thread);
783	>	assertThreadBlocks(thread, Thread.State.WAITING);
784		for (Thread thread : threads)
785		assertTrue(thread.isAlive());
786		assertState(phaser, 0, THREADS + 1, 1);

Diff Legend

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