Searched refs:wt (Results 1 – 6 of 6) sorted by relevance
/libcore/ojluni/src/main/java/java/util/concurrent/ |
D | ForkJoinTask.java | 381 int s; Thread t; ForkJoinWorkerThread wt; ForkJoinPool.WorkQueue w; in doJoin() local 384 (w = (wt = (ForkJoinWorkerThread)t).workQueue). in doJoin() 386 wt.pool.awaitJoin(w, this, 0L) : in doJoin() 396 int s; Thread t; ForkJoinWorkerThread wt; in doInvoke() local 399 (wt = (ForkJoinWorkerThread)t).pool. in doInvoke() 400 awaitJoin(wt.workQueue, this, 0L) : in doInvoke() 1026 ForkJoinWorkerThread wt = (ForkJoinWorkerThread)t; in get() local 1027 s = wt.pool.awaitJoin(wt.workQueue, this, deadline); in get() 1090 ForkJoinWorkerThread wt = (ForkJoinWorkerThread)t; in helpQuiesce() local 1091 wt.pool.helpQuiescePool(wt.workQueue); in helpQuiesce() [all …]
|
D | CountedCompleter.java | 707 Thread t; ForkJoinWorkerThread wt; in helpComplete() local 710 (wt = (ForkJoinWorkerThread)t).pool. in helpComplete() 711 helpComplete(wt.workQueue, this, maxTasks); in helpComplete()
|
D | ForkJoinPool.java | 1339 Thread wt; Thread.State s; in isApparentlyUnblocked() local 1341 (wt = owner) != null && in isApparentlyUnblocked() 1342 (s = wt.getState()) != Thread.State.BLOCKED && in isApparentlyUnblocked() 1546 ForkJoinWorkerThread wt = null; in createWorker() local 1549 if (fac != null && (wt = fac.newThread(this)) != null) { in createWorker() 1550 if (isSpare && (q = wt.workQueue) != null) in createWorker() 1552 wt.start(); in createWorker() 1558 deregisterWorker(wt, ex); in createWorker() 1588 final WorkQueue registerWorker(ForkJoinWorkerThread wt) { in registerWorker() argument 1591 wt.setDaemon(true); // configure thread in registerWorker() [all …]
|
D | ThreadPoolExecutor.java | 1146 Thread wt = Thread.currentThread(); in runWorker() local 1161 !wt.isInterrupted()) in runWorker() 1162 wt.interrupt(); in runWorker() 1164 beforeExecute(wt, task); in runWorker()
|
/libcore/ojluni/src/main/java/java/lang/invoke/ |
D | MethodType.java | 685 MethodType wt = pt.wrapAlt; in wrapWithPrims() local 686 if (wt == null) { in wrapWithPrims() 688 wt = MethodTypeForm.canonicalize(pt, MethodTypeForm.WRAP, MethodTypeForm.WRAP); in wrapWithPrims() 689 assert(wt != null); in wrapWithPrims() 690 pt.wrapAlt = wt; in wrapWithPrims() 692 return wt; in wrapWithPrims() 695 private static MethodType unwrapWithNoPrims(MethodType wt) { in unwrapWithNoPrims() argument 696 assert(!wt.hasPrimitives()); in unwrapWithNoPrims() 697 MethodType uwt = wt.wrapAlt; in unwrapWithNoPrims() 700 uwt = MethodTypeForm.canonicalize(wt, MethodTypeForm.UNWRAP, MethodTypeForm.UNWRAP); in unwrapWithNoPrims() [all …]
|
/libcore/ojluni/src/main/java/java/util/concurrent/locks/ |
D | StampedLock.java | 1114 Thread wt = Thread.currentThread(); in acquireWrite() 1115 U.putObject(wt, PARKBLOCKER, this); in acquireWrite() 1116 node.thread = wt; in acquireWrite() 1121 U.putObject(wt, PARKBLOCKER, null); in acquireWrite() 1223 Thread wt = Thread.currentThread(); in acquireRead() local 1224 U.putObject(wt, PARKBLOCKER, this); in acquireRead() 1225 node.thread = wt; in acquireRead() 1230 U.putObject(wt, PARKBLOCKER, null); in acquireRead() 1298 Thread wt = Thread.currentThread(); in acquireRead() 1299 U.putObject(wt, PARKBLOCKER, this); in acquireRead() [all …]
|