Home
last modified time | relevance | path

Searched refs:ForkJoinWorkerThread (Results 1 – 15 of 15) sorted by relevance

/libcore/ojluni/src/main/java/java/util/concurrent/
DForkJoinWorkerThread.java57 public class ForkJoinWorkerThread extends Thread { class
72 ForkJoinWorkerThread(ThreadGroup group, ForkJoinPool pool, in ForkJoinWorkerThread() method in ForkJoinWorkerThread
92 /* TODO: protected */ ForkJoinWorkerThread(ThreadGroup group, ForkJoinPool pool) { in ForkJoinWorkerThread() method in ForkJoinWorkerThread
102 protected ForkJoinWorkerThread(ForkJoinPool pool) { in ForkJoinWorkerThread() method in ForkJoinWorkerThread
187 static final class InnocuousForkJoinWorkerThread extends ForkJoinWorkerThread {
DForkJoinTask.java404 if ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) { in awaitDone()
405 ForkJoinWorkerThread wt = (ForkJoinWorkerThread)t; in awaitDone()
652 Thread t; ForkJoinWorkerThread w; in fork()
653 if ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) in fork()
654 (w = (ForkJoinWorkerThread)t).workQueue.push(this, w.pool); in fork()
1072 Thread t; ForkJoinWorkerThread w; ForkJoinPool p; in helpQuiesce()
1073 if ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread && in helpQuiesce()
1074 (p = (w = (ForkJoinWorkerThread)t).pool) != null) in helpQuiesce()
1112 return (((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) ? in getPool()
1113 ((ForkJoinWorkerThread) t).pool : null); in getPool()
[all …]
DForkJoinPool.java795 public ForkJoinWorkerThread newThread(ForkJoinPool pool); in newThread()
811 public final ForkJoinWorkerThread newThread(ForkJoinPool pool) { in newThread()
814 public ForkJoinWorkerThread run() { in newThread()
815 return new ForkJoinWorkerThread(null, pool, true, false); in newThread()
839 public final ForkJoinWorkerThread newThread(ForkJoinPool pool) {
842 public ForkJoinWorkerThread run() {
844 new ForkJoinWorkerThread(null, pool, true, true):
845 new ForkJoinWorkerThread.
888 final ForkJoinWorkerThread owner; // owning thread or null if shared
928 WorkQueue(ForkJoinWorkerThread owner, boolean isInnocuous) {
[all …]
DCountedCompleter.java727 if (owned = (t = Thread.currentThread()) instanceof ForkJoinWorkerThread) in helpComplete()
728 q = ((ForkJoinWorkerThread)t).workQueue; in helpComplete()
DCompletableFuture.java1862 if (Thread.currentThread() instanceof ForkJoinWorkerThread) in waitingGet()
1908 if (Thread.currentThread() instanceof ForkJoinWorkerThread) in timedGet()
/libcore/ojluni/src/main/java/java/util/stream/
DAbstractTask.java30 import java.util.concurrent.ForkJoinWorkerThread;
162 if (t instanceof ForkJoinWorkerThread) { in getLeafTarget()
163 return ((ForkJoinWorkerThread) t).getPool().getParallelism() << 2; in getLeafTarget()
/libcore/jsr166-tests/src/test/java/jsr166/
DRecursiveActionTest.java17 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()
DForkJoinPoolTest.java24 import java.util.concurrent.ForkJoinWorkerThread;
74 static class FailingFJWSubclass extends ForkJoinWorkerThread {
82 public ForkJoinWorkerThread newThread(ForkJoinPool p) { in newThread()
DForkJoinTask8Test.java18 import java.util.concurrent.ForkJoinWorkerThread;
1196 assertTrue(Thread.currentThread() instanceof ForkJoinWorkerThread);
/libcore/ojluni/src/test/java/util/concurrent/tck/
DRecursiveActionTest.java43 import java.util.concurrent.ForkJoinWorkerThread;
776 ForkJoinWorkerThread w = in testWorkerGetPool()
777 (ForkJoinWorkerThread) Thread.currentThread(); in testWorkerGetPool()
790 ForkJoinWorkerThread w = in testWorkerGetPoolIndex()
791 (ForkJoinWorkerThread) Thread.currentThread(); in testWorkerGetPoolIndex()
DForkJoinPoolTest.java50 import java.util.concurrent.ForkJoinWorkerThread;
92 static class FailingFJWSubclass extends ForkJoinWorkerThread {
100 public ForkJoinWorkerThread newThread(ForkJoinPool p) { in newThread()
DForkJoinTask8Test.java43 import java.util.concurrent.ForkJoinWorkerThread;
1219 assertTrue(Thread.currentThread() instanceof ForkJoinWorkerThread);
/libcore/
Dopenjdk_java_files.bp1004 "ojluni/src/main/java/java/util/concurrent/ForkJoinWorkerThread.java",
DEXPECTED_UPSTREAM1055 …a/util/concurrent/ForkJoinWorkerThread.java,jdk17u/jdk-17.0.6-ga,src/java.base/share/classes/java/…
/libcore/api/
Dcurrent.txt16008 …method public java.util.concurrent.ForkJoinWorkerThread newThread(java.util.concurrent.ForkJoinPoo…
16058 public class ForkJoinWorkerThread extends java.lang.Thread {
16059 ctor protected ForkJoinWorkerThread(java.util.concurrent.ForkJoinPool);