ViewVC Help

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

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

Comparing jsr166/src/test/tck/CountedCompleterTest.java (file contents):
Revision 1.37 by jsr166, Sun Jul 22 20:23:28 2018 UTC vs.
Revision 1.38 by dl, Tue Jan 26 13:33:05 2021 UTC

#	Line 47 | Line 47 | public class CountedCompleterTest extend
47		null, true);
48		}
49
50	<	private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask a) {
50	>	private void testInvokeOnPool(ForkJoinPool pool, ForkJoinTask<?> a) {
51		try (PoolCleaner cleaner = cleaner(pool)) {
52		assertFalse(a.isDone());
53		assertFalse(a.isCompletedNormally());
#	Line 67 | Line 67 | public class CountedCompleterTest extend
67		}
68		}
69
70	<	void checkNotDone(CountedCompleter a) {
70	>	void checkNotDone(CountedCompleter<?> a) {
71		assertFalse(a.isDone());
72		assertFalse(a.isCompletedNormally());
73		assertFalse(a.isCompletedAbnormally());
#	Line 118 | Line 118 | public class CountedCompleterTest extend
118		assertNull(v2);
119		}
120
121	<	void checkCancelled(CountedCompleter a) {
121	>	void checkCancelled(CountedCompleter<?> a) {
122		assertTrue(a.isDone());
123		assertTrue(a.isCancelled());
124		assertFalse(a.isCompletedNormally());
#	Line 155 | Line 155 | public class CountedCompleterTest extend
155		} catch (Throwable fail) { threadUnexpectedException(fail); }
156		}
157
158	<	void checkCompletedAbnormally(CountedCompleter a, Throwable t) {
158	>	void checkCompletedAbnormally(CountedCompleter<?> a, Throwable t) {
159		assertTrue(a.isDone());
160		assertFalse(a.isCancelled());
161		assertFalse(a.isCompletedNormally());
#	Line 218 | Line 218 | public class CountedCompleterTest extend
218		int setRawResultN() { return setRawResultN.get(); }
219
220		CheckedCC() { super(); }
221	<	CheckedCC(CountedCompleter p) { super(p); }
222	<	CheckedCC(CountedCompleter p, int n) { super(p, n); }
221	>	CheckedCC(CountedCompleter<?> p) { super(p); }
222	>	CheckedCC(CountedCompleter<?> p, int n) { super(p, n); }
223		abstract void realCompute();
224		public final void compute() {
225		computeN.incrementAndGet();
226		realCompute();
227		}
228	<	public void onCompletion(CountedCompleter caller) {
228	>	public void onCompletion(CountedCompleter<?> caller) {
229		onCompletionN.incrementAndGet();
230		super.onCompletion(caller);
231		}
232		public boolean onExceptionalCompletion(Throwable ex,
233	<	CountedCompleter caller) {
233	>	CountedCompleter<?> caller) {
234		onExceptionalCompletionN.incrementAndGet();
235		assertNotNull(ex);
236		assertTrue(isCompletedAbnormally());
#	Line 278 | Line 278 | public class CountedCompleterTest extend
278
279		final class NoopCC extends CheckedCC {
280		NoopCC() { super(); }
281	<	NoopCC(CountedCompleter p) { super(p); }
282	<	NoopCC(CountedCompleter p, int initialPendingCount) {
281	>	NoopCC(CountedCompleter<?> p) { super(p); }
282	>	NoopCC(CountedCompleter<?> p, int initialPendingCount) {
283		super(p, initialPendingCount);
284		}
285		protected void realCompute() {}
#	Line 400 | Line 400 | public class CountedCompleterTest extend
400		public void testGetCompleter() {
401		NoopCC a = new NoopCC();
402		assertNull(a.getCompleter());
403	<	CountedCompleter b = new NoopCC(a);
403	>	NoopCC b = new NoopCC(a);
404		assertSame(a, b.getCompleter());
405	<	CountedCompleter c = new NoopCC(b);
405	>	NoopCC c = new NoopCC(b);
406		assertSame(b, c.getCompleter());
407		}
408
#	Line 525 | Line 525 | public class CountedCompleterTest extend
525		int number;
526		int rnumber;
527
528	<	public CCF(CountedCompleter parent, int n) {
528	>	public CCF(CountedCompleter<?> parent, int n) {
529		super(parent, 1);
530		this.number = n;
531		}
#	Line 543 | Line 543 | public class CountedCompleterTest extend
543
544		final class LCCF extends CCF {
545		public LCCF(int n) { this(null, n); }
546	<	public LCCF(CountedCompleter parent, int n) {
546	>	public LCCF(CountedCompleter<?> parent, int n) {
547		super(parent, n);
548		}
549	<	public final void onCompletion(CountedCompleter caller) {
549	>	public final void onCompletion(CountedCompleter<?> caller) {
550		super.onCompletion(caller);
551		CCF p = (CCF)getCompleter();
552		int n = number + rnumber;
#	Line 557 | Line 557 | public class CountedCompleterTest extend
557		}
558		}
559		final class RCCF extends CCF {
560	<	public RCCF(CountedCompleter parent, int n) {
560	>	public RCCF(CountedCompleter<?> parent, int n) {
561		super(parent, n);
562		}
563	<	public final void onCompletion(CountedCompleter caller) {
563	>	public final void onCompletion(CountedCompleter<?> caller) {
564		super.onCompletion(caller);
565		CCF p = (CCF)getCompleter();
566		int n = number + rnumber;
#	Line 576 | Line 576 | public class CountedCompleterTest extend
576		int number;
577		int rnumber;
578
579	<	public FailingCCF(CountedCompleter parent, int n) {
579	>	public FailingCCF(CountedCompleter<?> parent, int n) {
580		super(parent, 1);
581		this.number = n;
582		}
#	Line 594 | Line 594 | public class CountedCompleterTest extend
594
595		final class LFCCF extends FailingCCF {
596		public LFCCF(int n) { this(null, n); }
597	<	public LFCCF(CountedCompleter parent, int n) {
597	>	public LFCCF(CountedCompleter<?> parent, int n) {
598		super(parent, n);
599		}
600	<	public final void onCompletion(CountedCompleter caller) {
600	>	public final void onCompletion(CountedCompleter<?> caller) {
601		super.onCompletion(caller);
602		FailingCCF p = (FailingCCF)getCompleter();
603		int n = number + rnumber;
#	Line 608 | Line 608 | public class CountedCompleterTest extend
608		}
609		}
610		final class RFCCF extends FailingCCF {
611	<	public RFCCF(CountedCompleter parent, int n) {
611	>	public RFCCF(CountedCompleter<?> parent, int n) {
612		super(parent, n);
613		}
614	<	public final void onCompletion(CountedCompleter caller) {
614	>	public final void onCompletion(CountedCompleter<?> caller) {
615		super.onCompletion(caller);
616		completeExceptionally(new FJException());
617		}
#	Line 623 | Line 623 | public class CountedCompleterTest extend
623		* completed tasks; getRawResult returns null.
624		*/
625		public void testInvoke() {
626	<	ForkJoinTask a = new CheckedRecursiveAction() {
626	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
627		protected void realCompute() {
628		CCF f = new LCCF(8);
629		assertNull(f.invoke());
#	Line 639 | Line 639 | public class CountedCompleterTest extend
639		* completed tasks
640		*/
641		public void testQuietlyInvoke() {
642	<	ForkJoinTask a = new CheckedRecursiveAction() {
642	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
643		protected void realCompute() {
644		CCF f = new LCCF(8);
645		f.quietlyInvoke();
#	Line 653 | Line 653 | public class CountedCompleterTest extend
653		* join of a forked task returns when task completes
654		*/
655		public void testForkJoin() {
656	<	ForkJoinTask a = new CheckedRecursiveAction() {
656	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
657		protected void realCompute() {
658		CCF f = new LCCF(8);
659		assertSame(f, f.fork());
#	Line 668 | Line 668 | public class CountedCompleterTest extend
668		* get of a forked task returns when task completes
669		*/
670		public void testForkGet() {
671	<	ForkJoinTask a = new CheckedRecursiveAction() {
671	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
672		protected void realCompute() throws Exception {
673		CCF f = new LCCF(8);
674		assertSame(f, f.fork());
#	Line 683 | Line 683 | public class CountedCompleterTest extend
683		* timed get of a forked task returns when task completes
684		*/
685		public void testForkTimedGet() {
686	<	ForkJoinTask a = new CheckedRecursiveAction() {
686	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
687		protected void realCompute() throws Exception {
688		CCF f = new LCCF(8);
689		assertSame(f, f.fork());
#	Line 698 | Line 698 | public class CountedCompleterTest extend
698		* timed get with null time unit throws NPE
699		*/
700		public void testForkTimedGetNPE() {
701	<	ForkJoinTask a = new CheckedRecursiveAction() {
701	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
702		protected void realCompute() throws Exception {
703		CCF f = new LCCF(8);
704		assertSame(f, f.fork());
#	Line 714 | Line 714 | public class CountedCompleterTest extend
714		* quietlyJoin of a forked task returns when task completes
715		*/
716		public void testForkQuietlyJoin() {
717	<	ForkJoinTask a = new CheckedRecursiveAction() {
717	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
718		protected void realCompute() {
719		CCF f = new LCCF(8);
720		assertSame(f, f.fork());
#	Line 730 | Line 730 | public class CountedCompleterTest extend
730		* getQueuedTaskCount returns 0 when quiescent
731		*/
732		public void testForkHelpQuiesce() {
733	<	ForkJoinTask a = new CheckedRecursiveAction() {
733	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
734		protected void realCompute() {
735		CCF f = new LCCF(8);
736		assertSame(f, f.fork());
#	Line 748 | Line 748 | public class CountedCompleterTest extend
748		* invoke task throws exception when task completes abnormally
749		*/
750		public void testAbnormalInvoke() {
751	<	ForkJoinTask a = new CheckedRecursiveAction() {
751	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
752		protected void realCompute() {
753		FailingCCF f = new LFCCF(8);
754		try {
#	Line 765 | Line 765 | public class CountedCompleterTest extend
765		* quietlyInvoke task returns when task completes abnormally
766		*/
767		public void testAbnormalQuietlyInvoke() {
768	<	ForkJoinTask a = new CheckedRecursiveAction() {
768	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
769		protected void realCompute() {
770		FailingCCF f = new LFCCF(8);
771		f.quietlyInvoke();
#	Line 779 | Line 779 | public class CountedCompleterTest extend
779		* join of a forked task throws exception when task completes abnormally
780		*/
781		public void testAbnormalForkJoin() {
782	<	ForkJoinTask a = new CheckedRecursiveAction() {
782	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
783		protected void realCompute() {
784		FailingCCF f = new LFCCF(8);
785		assertSame(f, f.fork());
#	Line 797 | Line 797 | public class CountedCompleterTest extend
797		* get of a forked task throws exception when task completes abnormally
798		*/
799		public void testAbnormalForkGet() {
800	<	ForkJoinTask a = new CheckedRecursiveAction() {
800	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
801		protected void realCompute() throws Exception {
802		FailingCCF f = new LFCCF(8);
803		assertSame(f, f.fork());
#	Line 817 | Line 817 | public class CountedCompleterTest extend
817		* timed get of a forked task throws exception when task completes abnormally
818		*/
819		public void testAbnormalForkTimedGet() {
820	<	ForkJoinTask a = new CheckedRecursiveAction() {
820	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
821		protected void realCompute() throws Exception {
822		FailingCCF f = new LFCCF(8);
823		assertSame(f, f.fork());
#	Line 837 | Line 837 | public class CountedCompleterTest extend
837		* quietlyJoin of a forked task returns when task completes abnormally
838		*/
839		public void testAbnormalForkQuietlyJoin() {
840	<	ForkJoinTask a = new CheckedRecursiveAction() {
840	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
841		protected void realCompute() {
842		FailingCCF f = new LFCCF(8);
843		assertSame(f, f.fork());
#	Line 852 | Line 852 | public class CountedCompleterTest extend
852		* invoke task throws exception when task cancelled
853		*/
854		public void testCancelledInvoke() {
855	<	ForkJoinTask a = new CheckedRecursiveAction() {
855	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
856		protected void realCompute() {
857		CCF f = new LCCF(8);
858		assertTrue(f.cancel(true));
#	Line 870 | Line 870 | public class CountedCompleterTest extend
870		* join of a forked task throws exception when task cancelled
871		*/
872		public void testCancelledForkJoin() {
873	<	ForkJoinTask a = new CheckedRecursiveAction() {
873	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
874		protected void realCompute() {
875		CCF f = new LCCF(8);
876		assertTrue(f.cancel(true));
#	Line 889 | Line 889 | public class CountedCompleterTest extend
889		* get of a forked task throws exception when task cancelled
890		*/
891		public void testCancelledForkGet() {
892	<	ForkJoinTask a = new CheckedRecursiveAction() {
892	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
893		protected void realCompute() throws Exception {
894		CCF f = new LCCF(8);
895		assertTrue(f.cancel(true));
#	Line 908 | Line 908 | public class CountedCompleterTest extend
908		* timed get of a forked task throws exception when task cancelled
909		*/
910		public void testCancelledForkTimedGet() throws Exception {
911	<	ForkJoinTask a = new CheckedRecursiveAction() {
911	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
912		protected void realCompute() throws Exception {
913		CCF f = new LCCF(8);
914		assertTrue(f.cancel(true));
#	Line 927 | Line 927 | public class CountedCompleterTest extend
927		* quietlyJoin of a forked task returns when task cancelled
928		*/
929		public void testCancelledForkQuietlyJoin() {
930	<	ForkJoinTask a = new CheckedRecursiveAction() {
930	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
931		protected void realCompute() {
932		CCF f = new LCCF(8);
933		assertTrue(f.cancel(true));
#	Line 943 | Line 943 | public class CountedCompleterTest extend
943		*/
944		public void testGetPool() {
945		final ForkJoinPool mainPool = mainPool();
946	<	ForkJoinTask a = new CheckedRecursiveAction() {
946	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
947		protected void realCompute() {
948		assertSame(mainPool, getPool());
949		}};
#	Line 954 | Line 954 | public class CountedCompleterTest extend
954		* getPool of non-FJ task returns null
955		*/
956		public void testGetPool2() {
957	<	ForkJoinTask a = new CheckedRecursiveAction() {
957	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
958		protected void realCompute() {
959		assertNull(getPool());
960		}};
#	Line 965 | Line 965 | public class CountedCompleterTest extend
965		* inForkJoinPool of executing task returns true
966		*/
967		public void testInForkJoinPool() {
968	<	ForkJoinTask a = new CheckedRecursiveAction() {
968	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
969		protected void realCompute() {
970		assertTrue(inForkJoinPool());
971		}};
#	Line 976 | Line 976 | public class CountedCompleterTest extend
976		* inForkJoinPool of non-FJ task returns false
977		*/
978		public void testInForkJoinPool2() {
979	<	ForkJoinTask a = new CheckedRecursiveAction() {
979	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
980		protected void realCompute() {
981		assertFalse(inForkJoinPool());
982		}};
#	Line 987 | Line 987 | public class CountedCompleterTest extend
987		* setRawResult(null) succeeds
988		*/
989		public void testSetRawResult() {
990	<	ForkJoinTask a = new CheckedRecursiveAction() {
990	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
991		protected void realCompute() {
992		setRawResult(null);
993		assertNull(getRawResult());
#	Line 999 | Line 999 | public class CountedCompleterTest extend
999		* invoke task throws exception after invoking completeExceptionally
1000		*/
1001		public void testCompleteExceptionally2() {
1002	<	ForkJoinTask a = new CheckedRecursiveAction() {
1002	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1003		protected void realCompute() {
1004		CCF n = new LCCF(8);
1005		CCF f = new LCCF(n, 8);
#	Line 1015 | Line 1015 | public class CountedCompleterTest extend
1015		* invokeAll(t1, t2) invokes all task arguments
1016		*/
1017		public void testInvokeAll2() {
1018	<	ForkJoinTask a = new CheckedRecursiveAction() {
1018	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1019		protected void realCompute() {
1020		CCF f = new LCCF(8);
1021		CCF g = new LCCF(9);
#	Line 1032 | Line 1032 | public class CountedCompleterTest extend
1032		* invokeAll(tasks) with 1 argument invokes task
1033		*/
1034		public void testInvokeAll1() {
1035	<	ForkJoinTask a = new CheckedRecursiveAction() {
1035	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1036		protected void realCompute() {
1037		CCF f = new LCCF(8);
1038		invokeAll(f);
#	Line 1046 | Line 1046 | public class CountedCompleterTest extend
1046		* invokeAll(tasks) with > 2 argument invokes tasks
1047		*/
1048		public void testInvokeAll3() {
1049	<	ForkJoinTask a = new CheckedRecursiveAction() {
1049	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1050		protected void realCompute() {
1051		CCF f = new LCCF(8);
1052		CCF g = new LCCF(9);
#	Line 1066 | Line 1066 | public class CountedCompleterTest extend
1066		* invokeAll(collection) invokes all tasks in the collection
1067		*/
1068		public void testInvokeAllCollection() {
1069	<	ForkJoinTask a = new CheckedRecursiveAction() {
1069	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1070		protected void realCompute() {
1071		CCF f = new LCCF(8);
1072		CCF g = new LCCF(9);
1073		CCF h = new LCCF(7);
1074	<	HashSet set = new HashSet();
1074	>	HashSet<CCF> set = new HashSet<CCF>();
1075		set.add(f);
1076		set.add(g);
1077		set.add(h);
#	Line 1090 | Line 1090 | public class CountedCompleterTest extend
1090		* invokeAll(tasks) with any null task throws NPE
1091		*/
1092		public void testInvokeAllNPE() {
1093	<	ForkJoinTask a = new CheckedRecursiveAction() {
1093	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1094		protected void realCompute() {
1095		CCF f = new LCCF(8);
1096		CCF g = new LCCF(9);
#	Line 1107 | Line 1107 | public class CountedCompleterTest extend
1107		* invokeAll(t1, t2) throw exception if any task does
1108		*/
1109		public void testAbnormalInvokeAll2() {
1110	<	ForkJoinTask a = new CheckedRecursiveAction() {
1110	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1111		protected void realCompute() {
1112		CCF f = new LCCF(8);
1113		FailingCCF g = new LFCCF(9);
#	Line 1125 | Line 1125 | public class CountedCompleterTest extend
1125		* invokeAll(tasks) with 1 argument throws exception if task does
1126		*/
1127		public void testAbnormalInvokeAll1() {
1128	<	ForkJoinTask a = new CheckedRecursiveAction() {
1128	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1129		protected void realCompute() {
1130		FailingCCF g = new LFCCF(9);
1131		try {
#	Line 1142 | Line 1142 | public class CountedCompleterTest extend
1142		* invokeAll(tasks) with > 2 argument throws exception if any task does
1143		*/
1144		public void testAbnormalInvokeAll3() {
1145	<	ForkJoinTask a = new CheckedRecursiveAction() {
1145	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1146		protected void realCompute() {
1147		CCF f = new LCCF(8);
1148		FailingCCF g = new LFCCF(9);
#	Line 1161 | Line 1161 | public class CountedCompleterTest extend
1161		* invokeAll(collection) throws exception if any task does
1162		*/
1163		public void testAbnormalInvokeAllCollection() {
1164	<	ForkJoinTask a = new CheckedRecursiveAction() {
1164	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1165		protected void realCompute() {
1166		FailingCCF f = new LFCCF(8);
1167		CCF g = new LCCF(9);
1168		CCF h = new LCCF(7);
1169	<	HashSet set = new HashSet();
1169	>	HashSet<ForkJoinTask<?>> set = new HashSet<ForkJoinTask<?>>();
1170		set.add(f);
1171		set.add(g);
1172		set.add(h);
#	Line 1185 | Line 1185 | public class CountedCompleterTest extend
1185		* and suppresses execution
1186		*/
1187		public void testTryUnfork() {
1188	<	ForkJoinTask a = new CheckedRecursiveAction() {
1188	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1189		protected void realCompute() {
1190		CCF g = new LCCF(9);
1191		assertSame(g, g.fork());
#	Line 1204 | Line 1204 | public class CountedCompleterTest extend
1204		* there are more tasks than threads
1205		*/
1206		public void testGetSurplusQueuedTaskCount() {
1207	<	ForkJoinTask a = new CheckedRecursiveAction() {
1207	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1208		protected void realCompute() {
1209		CCF h = new LCCF(7);
1210		assertSame(h, h.fork());
#	Line 1226 | Line 1226 | public class CountedCompleterTest extend
1226		* peekNextLocalTask returns most recent unexecuted task.
1227		*/
1228		public void testPeekNextLocalTask() {
1229	<	ForkJoinTask a = new CheckedRecursiveAction() {
1229	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1230		protected void realCompute() {
1231		CCF g = new LCCF(9);
1232		assertSame(g, g.fork());
#	Line 1246 | Line 1246 | public class CountedCompleterTest extend
1246		* executing it
1247		*/
1248		public void testPollNextLocalTask() {
1249	<	ForkJoinTask a = new CheckedRecursiveAction() {
1249	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1250		protected void realCompute() {
1251		CCF g = new LCCF(9);
1252		assertSame(g, g.fork());
#	Line 1265 | Line 1265 | public class CountedCompleterTest extend
1265		* pollTask returns an unexecuted task without executing it
1266		*/
1267		public void testPollTask() {
1268	<	ForkJoinTask a = new CheckedRecursiveAction() {
1268	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1269		protected void realCompute() {
1270		CCF g = new LCCF(9);
1271		assertSame(g, g.fork());
#	Line 1283 | Line 1283 | public class CountedCompleterTest extend
1283		* peekNextLocalTask returns least recent unexecuted task in async mode
1284		*/
1285		public void testPeekNextLocalTaskAsync() {
1286	<	ForkJoinTask a = new CheckedRecursiveAction() {
1286	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1287		protected void realCompute() {
1288		CCF g = new LCCF(9);
1289		assertSame(g, g.fork());
#	Line 1304 | Line 1304 | public class CountedCompleterTest extend
1304		* executing it, in async mode
1305		*/
1306		public void testPollNextLocalTaskAsync() {
1307	<	ForkJoinTask a = new CheckedRecursiveAction() {
1307	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1308		protected void realCompute() {
1309		CCF g = new LCCF(9);
1310		assertSame(g, g.fork());
#	Line 1324 | Line 1324 | public class CountedCompleterTest extend
1324		* async mode
1325		*/
1326		public void testPollTaskAsync() {
1327	<	ForkJoinTask a = new CheckedRecursiveAction() {
1327	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1328		protected void realCompute() {
1329		CCF g = new LCCF(9);
1330		assertSame(g, g.fork());
#	Line 1347 | Line 1347 | public class CountedCompleterTest extend
1347		* completed tasks; getRawResult returns null.
1348		*/
1349		public void testInvokeSingleton() {
1350	<	ForkJoinTask a = new CheckedRecursiveAction() {
1350	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1351		protected void realCompute() {
1352		CCF f = new LCCF(8);
1353		assertNull(f.invoke());
#	Line 1363 | Line 1363 | public class CountedCompleterTest extend
1363		* completed tasks
1364		*/
1365		public void testQuietlyInvokeSingleton() {
1366	<	ForkJoinTask a = new CheckedRecursiveAction() {
1366	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1367		protected void realCompute() {
1368		CCF f = new LCCF(8);
1369		f.quietlyInvoke();
#	Line 1377 | Line 1377 | public class CountedCompleterTest extend
1377		* join of a forked task returns when task completes
1378		*/
1379		public void testForkJoinSingleton() {
1380	<	ForkJoinTask a = new CheckedRecursiveAction() {
1380	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1381		protected void realCompute() {
1382		CCF f = new LCCF(8);
1383		assertSame(f, f.fork());
#	Line 1392 | Line 1392 | public class CountedCompleterTest extend
1392		* get of a forked task returns when task completes
1393		*/
1394		public void testForkGetSingleton() {
1395	<	ForkJoinTask a = new CheckedRecursiveAction() {
1395	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1396		protected void realCompute() throws Exception {
1397		CCF f = new LCCF(8);
1398		assertSame(f, f.fork());
#	Line 1407 | Line 1407 | public class CountedCompleterTest extend
1407		* timed get of a forked task returns when task completes
1408		*/
1409		public void testForkTimedGetSingleton() {
1410	<	ForkJoinTask a = new CheckedRecursiveAction() {
1410	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1411		protected void realCompute() throws Exception {
1412		CCF f = new LCCF(8);
1413		assertSame(f, f.fork());
#	Line 1422 | Line 1422 | public class CountedCompleterTest extend
1422		* timed get with null time unit throws NPE
1423		*/
1424		public void testForkTimedGetNPESingleton() {
1425	<	ForkJoinTask a = new CheckedRecursiveAction() {
1425	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1426		protected void realCompute() throws Exception {
1427		CCF f = new LCCF(8);
1428		assertSame(f, f.fork());
#	Line 1438 | Line 1438 | public class CountedCompleterTest extend
1438		* quietlyJoin of a forked task returns when task completes
1439		*/
1440		public void testForkQuietlyJoinSingleton() {
1441	<	ForkJoinTask a = new CheckedRecursiveAction() {
1441	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1442		protected void realCompute() {
1443		CCF f = new LCCF(8);
1444		assertSame(f, f.fork());
#	Line 1454 | Line 1454 | public class CountedCompleterTest extend
1454		* getQueuedTaskCount returns 0 when quiescent
1455		*/
1456		public void testForkHelpQuiesceSingleton() {
1457	<	ForkJoinTask a = new CheckedRecursiveAction() {
1457	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1458		protected void realCompute() {
1459		CCF f = new LCCF(8);
1460		assertSame(f, f.fork());
#	Line 1470 | Line 1470 | public class CountedCompleterTest extend
1470		* invoke task throws exception when task completes abnormally
1471		*/
1472		public void testAbnormalInvokeSingleton() {
1473	<	ForkJoinTask a = new CheckedRecursiveAction() {
1473	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1474		protected void realCompute() {
1475		FailingCCF f = new LFCCF(8);
1476		try {
#	Line 1487 | Line 1487 | public class CountedCompleterTest extend
1487		* quietlyInvoke task returns when task completes abnormally
1488		*/
1489		public void testAbnormalQuietlyInvokeSingleton() {
1490	<	ForkJoinTask a = new CheckedRecursiveAction() {
1490	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1491		protected void realCompute() {
1492		FailingCCF f = new LFCCF(8);
1493		f.quietlyInvoke();
#	Line 1501 | Line 1501 | public class CountedCompleterTest extend
1501		* join of a forked task throws exception when task completes abnormally
1502		*/
1503		public void testAbnormalForkJoinSingleton() {
1504	<	ForkJoinTask a = new CheckedRecursiveAction() {
1504	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1505		protected void realCompute() {
1506		FailingCCF f = new LFCCF(8);
1507		assertSame(f, f.fork());
#	Line 1519 | Line 1519 | public class CountedCompleterTest extend
1519		* get of a forked task throws exception when task completes abnormally
1520		*/
1521		public void testAbnormalForkGetSingleton() {
1522	<	ForkJoinTask a = new CheckedRecursiveAction() {
1522	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1523		protected void realCompute() throws Exception {
1524		FailingCCF f = new LFCCF(8);
1525		assertSame(f, f.fork());
#	Line 1539 | Line 1539 | public class CountedCompleterTest extend
1539		* timed get of a forked task throws exception when task completes abnormally
1540		*/
1541		public void testAbnormalForkTimedGetSingleton() {
1542	<	ForkJoinTask a = new CheckedRecursiveAction() {
1542	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1543		protected void realCompute() throws Exception {
1544		FailingCCF f = new LFCCF(8);
1545		assertSame(f, f.fork());
#	Line 1559 | Line 1559 | public class CountedCompleterTest extend
1559		* quietlyJoin of a forked task returns when task completes abnormally
1560		*/
1561		public void testAbnormalForkQuietlyJoinSingleton() {
1562	<	ForkJoinTask a = new CheckedRecursiveAction() {
1562	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1563		protected void realCompute() {
1564		FailingCCF f = new LFCCF(8);
1565		assertSame(f, f.fork());
#	Line 1574 | Line 1574 | public class CountedCompleterTest extend
1574		* invoke task throws exception when task cancelled
1575		*/
1576		public void testCancelledInvokeSingleton() {
1577	<	ForkJoinTask a = new CheckedRecursiveAction() {
1577	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1578		protected void realCompute() {
1579		CCF f = new LCCF(8);
1580		assertTrue(f.cancel(true));
#	Line 1592 | Line 1592 | public class CountedCompleterTest extend
1592		* join of a forked task throws exception when task cancelled
1593		*/
1594		public void testCancelledForkJoinSingleton() {
1595	<	ForkJoinTask a = new CheckedRecursiveAction() {
1595	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1596		protected void realCompute() {
1597		CCF f = new LCCF(8);
1598		assertTrue(f.cancel(true));
#	Line 1611 | Line 1611 | public class CountedCompleterTest extend
1611		* get of a forked task throws exception when task cancelled
1612		*/
1613		public void testCancelledForkGetSingleton() {
1614	<	ForkJoinTask a = new CheckedRecursiveAction() {
1614	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1615		protected void realCompute() throws Exception {
1616		CCF f = new LCCF(8);
1617		assertTrue(f.cancel(true));
#	Line 1630 | Line 1630 | public class CountedCompleterTest extend
1630		* timed get of a forked task throws exception when task cancelled
1631		*/
1632		public void testCancelledForkTimedGetSingleton() throws Exception {
1633	<	ForkJoinTask a = new CheckedRecursiveAction() {
1633	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1634		protected void realCompute() throws Exception {
1635		CCF f = new LCCF(8);
1636		assertTrue(f.cancel(true));
#	Line 1649 | Line 1649 | public class CountedCompleterTest extend
1649		* quietlyJoin of a forked task returns when task cancelled
1650		*/
1651		public void testCancelledForkQuietlyJoinSingleton() {
1652	<	ForkJoinTask a = new CheckedRecursiveAction() {
1652	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1653		protected void realCompute() {
1654		CCF f = new LCCF(8);
1655		assertTrue(f.cancel(true));
#	Line 1664 | Line 1664 | public class CountedCompleterTest extend
1664		* invoke task throws exception after invoking completeExceptionally
1665		*/
1666		public void testCompleteExceptionallySingleton() {
1667	<	ForkJoinTask a = new CheckedRecursiveAction() {
1667	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1668		protected void realCompute() {
1669		CCF n = new LCCF(8);
1670		CCF f = new LCCF(n, 8);
#	Line 1680 | Line 1680 | public class CountedCompleterTest extend
1680		* invokeAll(t1, t2) invokes all task arguments
1681		*/
1682		public void testInvokeAll2Singleton() {
1683	<	ForkJoinTask a = new CheckedRecursiveAction() {
1683	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1684		protected void realCompute() {
1685		CCF f = new LCCF(8);
1686		CCF g = new LCCF(9);
#	Line 1697 | Line 1697 | public class CountedCompleterTest extend
1697		* invokeAll(tasks) with 1 argument invokes task
1698		*/
1699		public void testInvokeAll1Singleton() {
1700	<	ForkJoinTask a = new CheckedRecursiveAction() {
1700	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1701		protected void realCompute() {
1702		CCF f = new LCCF(8);
1703		invokeAll(f);
#	Line 1711 | Line 1711 | public class CountedCompleterTest extend
1711		* invokeAll(tasks) with > 2 argument invokes tasks
1712		*/
1713		public void testInvokeAll3Singleton() {
1714	<	ForkJoinTask a = new CheckedRecursiveAction() {
1714	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1715		protected void realCompute() {
1716		CCF f = new LCCF(8);
1717		CCF g = new LCCF(9);
#	Line 1731 | Line 1731 | public class CountedCompleterTest extend
1731		* invokeAll(collection) invokes all tasks in the collection
1732		*/
1733		public void testInvokeAllCollectionSingleton() {
1734	<	ForkJoinTask a = new CheckedRecursiveAction() {
1734	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1735		protected void realCompute() {
1736		CCF f = new LCCF(8);
1737		CCF g = new LCCF(9);
1738		CCF h = new LCCF(7);
1739	<	HashSet set = new HashSet();
1739	>	HashSet<ForkJoinTask<?>> set = new HashSet<ForkJoinTask<?>>();
1740		set.add(f);
1741		set.add(g);
1742		set.add(h);
#	Line 1755 | Line 1755 | public class CountedCompleterTest extend
1755		* invokeAll(tasks) with any null task throws NPE
1756		*/
1757		public void testInvokeAllNPESingleton() {
1758	<	ForkJoinTask a = new CheckedRecursiveAction() {
1758	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1759		protected void realCompute() {
1760		CCF f = new LCCF(8);
1761		CCF g = new LCCF(9);
#	Line 1772 | Line 1772 | public class CountedCompleterTest extend
1772		* invokeAll(t1, t2) throw exception if any task does
1773		*/
1774		public void testAbnormalInvokeAll2Singleton() {
1775	<	ForkJoinTask a = new CheckedRecursiveAction() {
1775	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1776		protected void realCompute() {
1777		CCF f = new LCCF(8);
1778		FailingCCF g = new LFCCF(9);
#	Line 1790 | Line 1790 | public class CountedCompleterTest extend
1790		* invokeAll(tasks) with 1 argument throws exception if task does
1791		*/
1792		public void testAbnormalInvokeAll1Singleton() {
1793	<	ForkJoinTask a = new CheckedRecursiveAction() {
1793	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1794		protected void realCompute() {
1795		FailingCCF g = new LFCCF(9);
1796		try {
#	Line 1807 | Line 1807 | public class CountedCompleterTest extend
1807		* invokeAll(tasks) with > 2 argument throws exception if any task does
1808		*/
1809		public void testAbnormalInvokeAll3Singleton() {
1810	<	ForkJoinTask a = new CheckedRecursiveAction() {
1810	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1811		protected void realCompute() {
1812		CCF f = new LCCF(8);
1813		FailingCCF g = new LFCCF(9);
#	Line 1826 | Line 1826 | public class CountedCompleterTest extend
1826		* invokeAll(collection) throws exception if any task does
1827		*/
1828		public void testAbnormalInvokeAllCollectionSingleton() {
1829	<	ForkJoinTask a = new CheckedRecursiveAction() {
1829	>	CheckedRecursiveAction a = new CheckedRecursiveAction() {
1830		protected void realCompute() {
1831		FailingCCF f = new LFCCF(8);
1832		CCF g = new LCCF(9);
1833		CCF h = new LCCF(7);
1834	<	HashSet set = new HashSet();
1834	>	HashSet<ForkJoinTask<?>> set = new HashSet<ForkJoinTask<?>>();
1835		set.add(f);
1836		set.add(g);
1837		set.add(h);

Diff Legend

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