ViewVC Help

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

root/jsr166/jsr166/src/main/java/util/concurrent/ForkJoinPool.java

Comparing jsr166/src/main/java/util/concurrent/ForkJoinPool.java (file contents):
Revision 1.212 by jsr166, Sat Jul 12 15:34:10 2014 UTC vs.
Revision 1.213 by jsr166, Sat Jul 12 17:21:16 2014 UTC

#	Line 1011 | Line 1011 | public class ForkJoinPool extends Abstra
1011		}
1012
1013		/**
1014	<	* Executes the given task and any remaining local tasks
1014	>	* Executes the given task and any remaining local tasks.
1015		*/
1016		final void runTask(ForkJoinTask<?> task) {
1017		if (task != null) {
#	Line 1029 | Line 1029 | public class ForkJoinPool extends Abstra
1029
1030		/**
1031		* If present, removes from queue and executes the given task,
1032	<	* or any other cancelled task. Used only by awaitJoin
1032	>	* or any other cancelled task. Used only by awaitJoin.
1033		*
1034	<	* Returns true if queue empty and task not known to be done
1034	>	* @return true if queue empty and task not known to be done
1035		*/
1036		final boolean tryRemoveAndExec(ForkJoinTask<?> task) {
1037		ForkJoinTask<?>[] a; int m, s, b, n;
#	Line 1353 | Line 1353 | public class ForkJoinPool extends Abstra
1353		final String workerNamePrefix;       // to create worker name string
1354
1355		/**
1356	<	* Acquires the runState lock; returns current (locked) runState
1356	>	* Acquires the runState lock; returns current (locked) runState.
1357		*/
1358		private int lockRunState() {
1359		int rs;
#	Line 2375 | Line 2375 | public class ForkJoinPool extends Abstra
2375		}
2376
2377		/**
2378	<	* Returns common pool queue for an external thread
2378	>	* Returns common pool queue for an external thread.
2379		*/
2380		static WorkQueue commonSubmitterQueue() {
2381		ForkJoinPool p = common;
#	Line 2413 | Line 2413 | public class ForkJoinPool extends Abstra
2413		}
2414
2415		/**
2416	<	* Performs helpComplete for an external submitter
2416	>	* Performs helpComplete for an external submitter.
2417		*/
2418		final int externalHelpComplete(CountedCompleter<?> task, int maxTasks) {
2419		WorkQueue[] ws; int n;

Diff Legend

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