954 |
|
} |
955 |
|
|
956 |
|
/** |
957 |
< |
* If present, removes task from queue and executes |
957 |
> |
* If present, removes task from queue and executes it. |
958 |
|
*/ |
959 |
|
final void tryRemoveAndExec(ForkJoinTask<?> task) { |
960 |
|
ForkJoinTask<?>[] wa; int s, wal; |
992 |
|
|
993 |
|
/** |
994 |
|
* Tries to steal and run tasks within the target's |
995 |
< |
* computation until done, not found, or limit exceeded |
995 |
> |
* computation until done, not found, or limit exceeded. |
996 |
|
* |
997 |
|
* @param task root of CountedCompleter computation |
998 |
|
* @param limit max runs, or zero for no limit |
1040 |
|
// Operations on shared queues |
1041 |
|
|
1042 |
|
/** |
1043 |
< |
* Tries to lock shared queue by CASing phase field |
1043 |
> |
* Tries to lock shared queue by CASing phase field. |
1044 |
|
*/ |
1045 |
|
final boolean tryLockSharedQueue() { |
1046 |
|
return U.compareAndSwapInt(this, PHASE, 0, QLOCK); |