Searched refs:wt (Results 1 – 3 of 3) sorted by relevance
346 int s; Thread t; ForkJoinWorkerThread wt; ForkJoinPool.WorkQueue w; in doJoin() local349 (w = (wt = (ForkJoinWorkerThread)t).workQueue). in doJoin()351 wt.pool.awaitJoin(w, this) : in doJoin()361 int s; Thread t; ForkJoinWorkerThread wt; in doInvoke() local364 (wt = (ForkJoinWorkerThread)t).pool.awaitJoin(wt.workQueue, this) : in doInvoke()994 ForkJoinWorkerThread wt = (ForkJoinWorkerThread)t; in get() local995 p = wt.pool; in get()996 w = wt.workQueue; in get()1084 ForkJoinWorkerThread wt = (ForkJoinWorkerThread)t; in helpQuiesce() local1085 wt.pool.helpQuiescePool(wt.workQueue); in helpQuiesce()[all …]
1007 Thread wt; Thread.State s; in isApparentlyUnblocked() local1009 (wt = owner) != null && in isApparentlyUnblocked()1010 (s = wt.getState()) != Thread.State.BLOCKED && in isApparentlyUnblocked()1293 ForkJoinWorkerThread wt = null; in tryAddWorker() local1296 (wt = fac.newThread(this)) != null) { in tryAddWorker()1297 wt.start(); in tryAddWorker()1303 deregisterWorker(wt, ex); in tryAddWorker()1321 final WorkQueue registerWorker(ForkJoinWorkerThread wt) { in registerWorker() argument1323 wt.setDaemon(true); in registerWorker()1325 wt.setUncaughtExceptionHandler(handler); in registerWorker()[all …]
1092 Thread wt = Thread.currentThread(); in runWorker() local1107 !wt.isInterrupted()) in runWorker()1108 wt.interrupt(); in runWorker()1110 beforeExecute(wt, task); in runWorker()