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.java1339 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 …]
DThreadPoolExecutor.java1146 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/
DMethodType.java685 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/
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 …]