Home
last modified time | relevance | path

Searched refs:wt (Results 1 – 6 of 6) sorted by relevance

/libcore/ojluni/src/main/java/java/util/concurrent/
DForkJoinTask.java381 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 …]
DCountedCompleter.java707 Thread t; ForkJoinWorkerThread wt; in helpComplete() local
710 (wt = (ForkJoinWorkerThread)t).pool. in helpComplete()
711 helpComplete(wt.workQueue, this, maxTasks); in helpComplete()
DForkJoinPool.java1336 Thread wt; Thread.State s; in isApparentlyUnblocked() local
1338 (wt = owner) != null && in isApparentlyUnblocked()
1339 (s = wt.getState()) != Thread.State.BLOCKED && in isApparentlyUnblocked()
1543 ForkJoinWorkerThread wt = null; in createWorker() local
1546 if (fac != null && (wt = fac.newThread(this)) != null) { in createWorker()
1547 if (isSpare && (q = wt.workQueue) != null) in createWorker()
1549 wt.start(); in createWorker()
1555 deregisterWorker(wt, ex); in createWorker()
1585 final WorkQueue registerWorker(ForkJoinWorkerThread wt) { in registerWorker() argument
1588 wt.setDaemon(true); // configure thread in registerWorker()
[all …]
DThreadPoolExecutor.java1141 Thread wt = Thread.currentThread(); in runWorker() local
1156 !wt.isInterrupted()) in runWorker()
1157 wt.interrupt(); in runWorker()
1159 beforeExecute(wt, task); in runWorker()
/libcore/ojluni/src/main/java/java/lang/invoke/
DMethodType.java680 MethodType wt = pt.wrapAlt; in wrapWithPrims() local
681 if (wt == null) { in wrapWithPrims()
683 wt = MethodTypeForm.canonicalize(pt, MethodTypeForm.WRAP, MethodTypeForm.WRAP); in wrapWithPrims()
684 assert(wt != null); in wrapWithPrims()
685 pt.wrapAlt = wt; in wrapWithPrims()
687 return wt; in wrapWithPrims()
690 private static MethodType unwrapWithNoPrims(MethodType wt) { in unwrapWithNoPrims() argument
691 assert(!wt.hasPrimitives()); in unwrapWithNoPrims()
692 MethodType uwt = wt.wrapAlt; in unwrapWithNoPrims()
695 uwt = MethodTypeForm.canonicalize(wt, MethodTypeForm.UNWRAP, MethodTypeForm.UNWRAP); in unwrapWithNoPrims()
[all …]
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DStampedLock.java1114 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 …]