Lines Matching defs:wt
1148 Thread wt; Thread.State s;
1149 return ((wt = owner) != null &&
1150 (s = wt.getState()) != Thread.State.BLOCKED &&
1315 ForkJoinWorkerThread wt = null;
1317 if (fac != null && (wt = fac.newThread(this)) != null) {
1318 wt.start();
1324 deregisterWorker(wt, ex);
1351 * @param wt the worker thread
1354 final WorkQueue registerWorker(ForkJoinWorkerThread wt) {
1356 wt.setDaemon(true); // configure thread
1358 wt.setUncaughtExceptionHandler(handler);
1359 WorkQueue w = new WorkQueue(this, wt);
1405 wt.setName(prefix.concat(Integer.toString(tid)));
1416 * @param wt the worker thread, or null if construction failed
1419 final void deregisterWorker(ForkJoinWorkerThread wt, Throwable ex) {
1422 if (wt != null && (w = wt.workQueue) != null) {
1540 WorkQueue q; Thread wt; Thread.State ts;
1548 if ((wt = q.owner) != null &&
1549 ((ts = wt.getState()) == Thread.State.BLOCKED ||
2055 Thread t; ForkJoinWorkerThread wt; ForkJoinPool pool; WorkQueue q;
2057 (pool = (wt = (ForkJoinWorkerThread)t).pool) != null &&
2058 (q = wt.workQueue) != null) {
2131 ForkJoinWorkerThread wt = w.owner;
2133 if (wt != null) {
2135 wt.interrupt();
3004 ForkJoinWorkerThread wt;
3007 (wt = (ForkJoinWorkerThread)thread).pool == this) {
3008 helpQuiescePool(wt.workQueue);
3137 ForkJoinWorkerThread wt;
3141 (p = (wt = (ForkJoinWorkerThread)t).pool) != null &&
3142 (w = wt.workQueue) != null) {
3169 WorkQueue w; ForkJoinWorkerThread wt; WorkQueue[] ws; int r, n;
3173 (wt = (ForkJoinWorkerThread)thread).pool == p)
3174 w = wt.workQueue;