Searched refs:wt (Results 1 – 3 of 3) sorted by relevance
352 int s; Thread t; ForkJoinWorkerThread wt; ForkJoinPool.WorkQueue w; in doJoin() local355 (w = (wt = (ForkJoinWorkerThread)t).workQueue). in doJoin()357 wt.pool.awaitJoin(w, this) : in doJoin()367 int s; Thread t; ForkJoinWorkerThread wt; in doInvoke() local370 (wt = (ForkJoinWorkerThread)t).pool.awaitJoin(wt.workQueue, this) : in doInvoke()998 ForkJoinWorkerThread wt = (ForkJoinWorkerThread)t; in get() local999 p = wt.pool; in get()1000 w = wt.workQueue; in get()1088 ForkJoinWorkerThread wt = (ForkJoinWorkerThread)t; in helpQuiesce() local1089 wt.pool.helpQuiescePool(wt.workQueue); in helpQuiesce()[all …]
1014 Thread wt; Thread.State s; in isApparentlyUnblocked() local1016 (wt = owner) != null && in isApparentlyUnblocked()1017 (s = wt.getState()) != Thread.State.BLOCKED && in isApparentlyUnblocked()1300 ForkJoinWorkerThread wt = null; in tryAddWorker() local1303 (wt = fac.newThread(this)) != null) { in tryAddWorker()1304 wt.start(); in tryAddWorker()1310 deregisterWorker(wt, ex); in tryAddWorker()1328 final WorkQueue registerWorker(ForkJoinWorkerThread wt) { in registerWorker() argument1330 wt.setDaemon(true); in registerWorker()1332 wt.setUncaughtExceptionHandler(handler); in registerWorker()[all …]
1091 Thread wt = Thread.currentThread(); in runWorker() local1106 !wt.isInterrupted()) in runWorker()1107 wt.interrupt(); in runWorker()1109 beforeExecute(wt, task); in runWorker()