586 |
|
|
587 |
|
public void execute(Runnable task) { |
588 |
|
ForkJoinTask<?> job; |
589 |
< |
if (task instanceof AdaptedCallable) // avoid re-wrap |
590 |
< |
job = (AdaptedCallable<?>)task; |
591 |
< |
else if (task instanceof AdaptedRunnable) |
592 |
< |
job = (AdaptedRunnable<?>)task; |
589 |
> |
if (task instanceof ForkJoinTask) // avoid re-wrap |
590 |
> |
job = (ForkJoinTask<?>)task; |
591 |
|
else |
592 |
|
job = new AdaptedRunnable<Void>(task, null); |
593 |
|
doSubmit(job); |
607 |
|
|
608 |
|
public ForkJoinTask<?> submit(Runnable task) { |
609 |
|
ForkJoinTask<?> job; |
610 |
< |
if (task instanceof AdaptedCallable) // avoid re-wrap |
611 |
< |
job = (AdaptedCallable<?>)task; |
614 |
< |
else if (task instanceof AdaptedRunnable) |
615 |
< |
job = (AdaptedRunnable<?>)task; |
610 |
> |
if (task instanceof ForkJoinTask) // avoid re-wrap |
611 |
> |
job = (ForkJoinTask<?>)task; |
612 |
|
else |
613 |
|
job = new AdaptedRunnable<Void>(task, null); |
614 |
|
doSubmit(job); |
1915 |
|
} |
1916 |
|
|
1917 |
|
private static final sun.misc.Unsafe UNSAFE = getUnsafe(); |
1918 |
< |
static final long eventCountOffset = |
1918 |
> |
private static final long eventCountOffset = |
1919 |
|
fieldOffset("eventCount", ForkJoinPool.class); |
1920 |
< |
static final long workerCountsOffset = |
1920 |
> |
private static final long workerCountsOffset = |
1921 |
|
fieldOffset("workerCounts", ForkJoinPool.class); |
1922 |
< |
static final long runControlOffset = |
1922 |
> |
private static final long runControlOffset = |
1923 |
|
fieldOffset("runControl", ForkJoinPool.class); |
1924 |
< |
static final long syncStackOffset = |
1924 |
> |
private static final long syncStackOffset = |
1925 |
|
fieldOffset("syncStack",ForkJoinPool.class); |
1926 |
< |
static final long spareStackOffset = |
1926 |
> |
private static final long spareStackOffset = |
1927 |
|
fieldOffset("spareStack", ForkJoinPool.class); |
1928 |
|
|
1929 |
|
private boolean casEventCount(long cmp, long val) { |