ViewVC Help

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

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

Comparing jsr166/src/test/tck/LinkedBlockingDequeTest.java (file contents):
Revision 1.34 by jsr166, Sun Nov 28 08:43:53 2010 UTC vs.
Revision 1.37 by dl, Fri May 6 11:22:07 2011 UTC

#	Line 1 | Line 1
1		/*
2		* Written by Doug Lea with assistance from members of JCP JSR-166
3		* Expert Group and released to the public domain, as explained at
4	<	* http://creativecommons.org/licenses/publicdomain
4	>	* http://creativecommons.org/publicdomain/zero/1.0/
5		*/
6
7		import junit.framework.*;
#	Line 617 | Line 617 | public class LinkedBlockingDequeTest ext
617		}});
618
619		t.start();
620	<	Thread.sleep(SHORT_DELAY_MS);
620	>	delay(SHORT_DELAY_MS);
621		t.interrupt();
622		t.join();
623		assertEquals(SIZE, q.size());
#	Line 641 | Line 641 | public class LinkedBlockingDequeTest ext
641		}});
642
643		t.start();
644	<	Thread.sleep(SHORT_DELAY_MS);
644	>	delay(SHORT_DELAY_MS);
645		assertEquals(q.remainingCapacity(), 0);
646		assertEquals(0, q.take());
647	<	Thread.sleep(SHORT_DELAY_MS);
647	>	delay(SHORT_DELAY_MS);
648		t.interrupt();
649		t.join();
650		assertEquals(q.remainingCapacity(), 0);
#	Line 667 | Line 667 | public class LinkedBlockingDequeTest ext
667		}});
668
669		t.start();
670	<	Thread.sleep(SMALL_DELAY_MS);
670	>	delay(SMALL_DELAY_MS);
671		t.interrupt();
672		t.join();
673		}
#	Line 699 | Line 699 | public class LinkedBlockingDequeTest ext
699		}});
700
701		t.start();
702	<	Thread.sleep(SHORT_DELAY_MS);
702	>	delay(SHORT_DELAY_MS);
703		t.interrupt();
704		t.join();
705		}
#	Line 772 | Line 772 | public class LinkedBlockingDequeTest ext
772		/**
773		* putFirst(null) throws NPE
774		*/
775	<	public void testPutFirstNull() throws InterruptedException {
775	>	public void testPutFirstNull() throws InterruptedException {
776		try {
777		LinkedBlockingDeque q = new LinkedBlockingDeque(SIZE);
778		q.putFirst(null);
779		shouldThrow();
780		} catch (NullPointerException success) {}
781	<	}
781	>	}
782
783		/**
784		* all elements successfully putFirst are contained
785		*/
786	<	public void testPutFirst() throws InterruptedException {
787	<	LinkedBlockingDeque q = new LinkedBlockingDeque(SIZE);
788	<	for (int i = 0; i < SIZE; ++i) {
789	<	Integer I = new Integer(i);
790	<	q.putFirst(I);
791	<	assertTrue(q.contains(I));
792	<	}
793	<	assertEquals(0, q.remainingCapacity());
786	>	public void testPutFirst() throws InterruptedException {
787	>	LinkedBlockingDeque q = new LinkedBlockingDeque(SIZE);
788	>	for (int i = 0; i < SIZE; ++i) {
789	>	Integer I = new Integer(i);
790	>	q.putFirst(I);
791	>	assertTrue(q.contains(I));
792	>	}
793	>	assertEquals(0, q.remainingCapacity());
794		}
795
796		/**
#	Line 811 | Line 811 | public class LinkedBlockingDequeTest ext
811		}});
812
813		t.start();
814	<	Thread.sleep(SHORT_DELAY_MS);
814	>	delay(SHORT_DELAY_MS);
815		t.interrupt();
816		t.join();
817		assertEquals(SIZE, q.size());
#	Line 835 | Line 835 | public class LinkedBlockingDequeTest ext
835		}});
836
837		t.start();
838	<	Thread.sleep(SHORT_DELAY_MS);
838	>	delay(SHORT_DELAY_MS);
839		assertEquals(q.remainingCapacity(), 0);
840		assertEquals(capacity - 1, q.take());
841	<	Thread.sleep(SHORT_DELAY_MS);
841	>	delay(SHORT_DELAY_MS);
842		t.interrupt();
843		t.join();
844		assertEquals(q.remainingCapacity(), 0);
#	Line 861 | Line 861 | public class LinkedBlockingDequeTest ext
861		}});
862
863		t.start();
864	<	Thread.sleep(SMALL_DELAY_MS);
864	>	delay(SMALL_DELAY_MS);
865		t.interrupt();
866		t.join();
867		}
#	Line 887 | Line 887 | public class LinkedBlockingDequeTest ext
887		}};
888
889		t.start();
890	<	Thread.sleep(SHORT_DELAY_MS);
890	>	delay(SHORT_DELAY_MS);
891		t.interrupt();
892		t.join();
893		}
#	Line 908 | Line 908 | public class LinkedBlockingDequeTest ext
908		}});
909
910		t.start();
911	<	Thread.sleep(SHORT_DELAY_MS);
911	>	delay(SHORT_DELAY_MS);
912		t.interrupt();
913		t.join();
914		}
#	Line 954 | Line 954 | public class LinkedBlockingDequeTest ext
954		}});
955
956		t.start();
957	<	Thread.sleep(SHORT_DELAY_MS);
957	>	delay(SHORT_DELAY_MS);
958		t.interrupt();
959		t.join();
960		}
#	Line 976 | Line 976 | public class LinkedBlockingDequeTest ext
976		}});
977
978		t.start();
979	<	Thread.sleep(SMALL_DELAY_MS);
979	>	delay(SMALL_DELAY_MS);
980		assertTrue(q.offerFirst(zero, SHORT_DELAY_MS, MILLISECONDS));
981		t.interrupt();
982		t.join();
#	Line 985 | Line 985 | public class LinkedBlockingDequeTest ext
985		/**
986		* putLast(null) throws NPE
987		*/
988	<	public void testPutLastNull() throws InterruptedException {
988	>	public void testPutLastNull() throws InterruptedException {
989		try {
990		LinkedBlockingDeque q = new LinkedBlockingDeque(SIZE);
991		q.putLast(null);
992		shouldThrow();
993		} catch (NullPointerException success) {}
994	<	}
994	>	}
995
996		/**
997		* all elements successfully putLast are contained
998		*/
999	<	public void testPutLast() throws InterruptedException {
1000	<	LinkedBlockingDeque q = new LinkedBlockingDeque(SIZE);
1001	<	for (int i = 0; i < SIZE; ++i) {
1002	<	Integer I = new Integer(i);
1003	<	q.putLast(I);
1004	<	assertTrue(q.contains(I));
1005	<	}
1006	<	assertEquals(0, q.remainingCapacity());
999	>	public void testPutLast() throws InterruptedException {
1000	>	LinkedBlockingDeque q = new LinkedBlockingDeque(SIZE);
1001	>	for (int i = 0; i < SIZE; ++i) {
1002	>	Integer I = new Integer(i);
1003	>	q.putLast(I);
1004	>	assertTrue(q.contains(I));
1005	>	}
1006	>	assertEquals(0, q.remainingCapacity());
1007		}
1008
1009		/**
#	Line 1024 | Line 1024 | public class LinkedBlockingDequeTest ext
1024		}});
1025
1026		t.start();
1027	<	Thread.sleep(SHORT_DELAY_MS);
1027	>	delay(SHORT_DELAY_MS);
1028		t.interrupt();
1029		t.join();
1030		assertEquals(SIZE, q.size());
#	Line 1048 | Line 1048 | public class LinkedBlockingDequeTest ext
1048		}});
1049
1050		t.start();
1051	<	Thread.sleep(SHORT_DELAY_MS);
1051	>	delay(SHORT_DELAY_MS);
1052		assertEquals(q.remainingCapacity(), 0);
1053		assertEquals(0, q.take());
1054	<	Thread.sleep(SHORT_DELAY_MS);
1054	>	delay(SHORT_DELAY_MS);
1055		t.interrupt();
1056		t.join();
1057		assertEquals(q.remainingCapacity(), 0);
#	Line 1074 | Line 1074 | public class LinkedBlockingDequeTest ext
1074		}});
1075
1076		t.start();
1077	<	Thread.sleep(SMALL_DELAY_MS);
1077	>	delay(SMALL_DELAY_MS);
1078		t.interrupt();
1079		t.join();
1080		}
#	Line 1100 | Line 1100 | public class LinkedBlockingDequeTest ext
1100		}};
1101
1102		t.start();
1103	<	Thread.sleep(SHORT_DELAY_MS);
1103	>	delay(SHORT_DELAY_MS);
1104		t.interrupt();
1105		t.join();
1106		}
#	Line 1121 | Line 1121 | public class LinkedBlockingDequeTest ext
1121		}});
1122
1123		t.start();
1124	<	Thread.sleep(SHORT_DELAY_MS);
1124	>	delay(SHORT_DELAY_MS);
1125		t.interrupt();
1126		t.join();
1127		}
#	Line 1166 | Line 1166 | public class LinkedBlockingDequeTest ext
1166		}});
1167
1168		t.start();
1169	<	Thread.sleep(SHORT_DELAY_MS);
1169	>	delay(SHORT_DELAY_MS);
1170		t.interrupt();
1171		t.join();
1172		}
#	Line 1188 | Line 1188 | public class LinkedBlockingDequeTest ext
1188		}});
1189
1190		t.start();
1191	<	Thread.sleep(SMALL_DELAY_MS);
1191	>	delay(SMALL_DELAY_MS);
1192		assertTrue(q.offerLast(zero, SHORT_DELAY_MS, MILLISECONDS));
1193		t.interrupt();
1194		t.join();
#	Line 1508 | Line 1508 | public class LinkedBlockingDequeTest ext
1508
1509		executor.execute(new CheckedRunnable() {
1510		public void realRun() throws InterruptedException {
1511	<	Thread.sleep(SMALL_DELAY_MS);
1511	>	delay(SMALL_DELAY_MS);
1512		assertSame(one, q.take());
1513		}});
1514
#	Line 1530 | Line 1530 | public class LinkedBlockingDequeTest ext
1530
1531		executor.execute(new CheckedRunnable() {
1532		public void realRun() throws InterruptedException {
1533	<	Thread.sleep(SMALL_DELAY_MS);
1533	>	delay(SMALL_DELAY_MS);
1534		q.put(one);
1535		}});
1536

Diff Legend

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