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

Comparing jsr166/src/test/tck/LinkedBlockingDequeTest.java (file contents):
Revision 1.71 by jsr166, Sat May 13 21:52:59 2017 UTC vs.
Revision 1.72 by jsr166, Sat May 13 22:17:12 2017 UTC

# Line 604 | Line 604 | public class LinkedBlockingDequeTest ext
604              }});
605  
606          await(pleaseInterrupt);
607 <        assertThreadStaysAlive(t);
607 >        assertThreadBlocks(t, Thread.State.WAITING);
608          t.interrupt();
609          awaitTermination(t);
610          assertEquals(SIZE, q.size());
# Line 666 | Line 666 | public class LinkedBlockingDequeTest ext
666              }});
667  
668          await(pleaseInterrupt);
669 <        assertThreadStaysAlive(t);
669 >        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
670          t.interrupt();
671          awaitTermination(t);
672      }
# Line 832 | Line 832 | public class LinkedBlockingDequeTest ext
832              }});
833  
834          await(pleaseInterrupt);
835 <        assertThreadStaysAlive(t);
835 >        assertThreadBlocks(t, Thread.State.WAITING);
836          t.interrupt();
837          awaitTermination(t);
838          assertEquals(SIZE, q.size());
# Line 867 | Line 867 | public class LinkedBlockingDequeTest ext
867          assertEquals(capacity - 1, q.take());
868  
869          await(pleaseInterrupt);
870 <        assertThreadStaysAlive(t);
870 >        assertThreadBlocks(t, Thread.State.WAITING);
871          t.interrupt();
872          awaitTermination(t);
873          assertEquals(0, q.remainingCapacity());
# Line 894 | Line 894 | public class LinkedBlockingDequeTest ext
894              }});
895  
896          await(pleaseInterrupt);
897 <        assertThreadStaysAlive(t);
897 >        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
898          t.interrupt();
899          awaitTermination(t);
900      }
# Line 1179 | Line 1179 | public class LinkedBlockingDequeTest ext
1179              }});
1180  
1181          await(pleaseInterrupt);
1182 <        assertThreadStaysAlive(t);
1182 >        assertThreadBlocks(t, Thread.State.WAITING);
1183          t.interrupt();
1184          awaitTermination(t);
1185          assertEquals(SIZE, q.size());
# Line 1214 | Line 1214 | public class LinkedBlockingDequeTest ext
1214          assertEquals(0, q.take());
1215  
1216          await(pleaseInterrupt);
1217 <        assertThreadStaysAlive(t);
1217 >        assertThreadBlocks(t, Thread.State.WAITING);
1218          t.interrupt();
1219          awaitTermination(t);
1220          assertEquals(0, q.remainingCapacity());
# Line 1241 | Line 1241 | public class LinkedBlockingDequeTest ext
1241              }});
1242  
1243          await(pleaseInterrupt);
1244 <        assertThreadStaysAlive(t);
1244 >        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
1245          t.interrupt();
1246          awaitTermination(t);
1247      }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines