Searched refs:ForkJoinWorkerThread (Results 1 – 8 of 8) sorted by relevance
381 int s; Thread t; ForkJoinWorkerThread wt; ForkJoinPool.WorkQueue w; in doJoin()383 ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) ? in doJoin()384 (w = (wt = (ForkJoinWorkerThread)t).workQueue). in doJoin()396 int s; Thread t; ForkJoinWorkerThread wt; in doInvoke()398 ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) ? in doInvoke()399 (wt = (ForkJoinWorkerThread)t).pool. in doInvoke()691 if ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) in fork()692 ((ForkJoinWorkerThread)t).workQueue.push(this); in fork()992 int s = (Thread.currentThread() instanceof ForkJoinWorkerThread) ? in get()1025 if (t instanceof ForkJoinWorkerThread) { in get()[all …]
55 public class ForkJoinWorkerThread extends Thread { class82 protected ForkJoinWorkerThread(ForkJoinPool pool) { in ForkJoinWorkerThread() method in ForkJoinWorkerThread92 ForkJoinWorkerThread(ForkJoinPool pool, ThreadGroup threadGroup, in ForkJoinWorkerThread() method in ForkJoinWorkerThread210 static final class InnocuousForkJoinWorkerThread extends ForkJoinWorkerThread {
707 Thread t; ForkJoinWorkerThread wt; in helpComplete()709 if ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) in helpComplete()710 (wt = (ForkJoinWorkerThread)t).pool. in helpComplete()
710 public ForkJoinWorkerThread newThread(ForkJoinPool pool); in newThread()719 public final ForkJoinWorkerThread newThread(ForkJoinPool pool) { in newThread()720 return new ForkJoinWorkerThread(pool); in newThread()819 final ForkJoinWorkerThread owner; // owning thread or null if shared826 WorkQueue(ForkJoinPool pool, ForkJoinWorkerThread owner) { in WorkQueue()1158 ForkJoinWorkerThread thread = owner; in runTask()1543 ForkJoinWorkerThread wt = null; in createWorker()1585 final WorkQueue registerWorker(ForkJoinWorkerThread wt) { in registerWorker()1634 final void deregisterWorker(ForkJoinWorkerThread wt, Throwable ex) { in deregisterWorker()2385 Thread t; ForkJoinWorkerThread wt; ForkJoinPool pool; WorkQueue q; in getSurplusQueuedTaskCount()[all …]
17 import java.util.concurrent.ForkJoinWorkerThread;764 ForkJoinWorkerThread w = in testWorkerGetPool()765 (ForkJoinWorkerThread) Thread.currentThread(); in testWorkerGetPool()778 ForkJoinWorkerThread w = in testWorkerGetPoolIndex()779 (ForkJoinWorkerThread) Thread.currentThread(); in testWorkerGetPoolIndex()
24 import java.util.concurrent.ForkJoinWorkerThread;74 static class FailingFJWSubclass extends ForkJoinWorkerThread {82 public ForkJoinWorkerThread newThread(ForkJoinPool p) { in newThread()
18 import java.util.concurrent.ForkJoinWorkerThread;1196 assertTrue(Thread.currentThread() instanceof ForkJoinWorkerThread);
952 ojluni/src/main/java/java/util/concurrent/ForkJoinWorkerThread.java \