Searched refs:QNode (Results 1 – 2 of 2) sorted by relevance
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | SynchronousQueue.java | 505 static final class QNode implements ForkJoinPool.ManagedBlocker { class in SynchronousQueue.TransferQueue
506 volatile QNode next; // next node in queue
511 QNode(Object item, boolean isData) { in QNode() method in SynchronousQueue.TransferQueue.QNode
516 boolean casNext(QNode cmp, QNode val) { in casNext()
573 QITEM = l.findVarHandle(QNode.class, "item", Object.class);
574 QNEXT = l.findVarHandle(QNode.class, "next", QNode.class);
575 QWAITER = l.findVarHandle(QNode.class, "waiter", Thread.class);
583 transient volatile QNode head;
585 transient volatile QNode tail;
591 transient volatile QNode cleanMe;
[all …]
|
| D | Phaser.java | 351 private final AtomicReference<QNode> evenQ;
352 private final AtomicReference<QNode> oddQ;
562 this.evenQ = new AtomicReference<QNode>(); in Phaser()
563 this.oddQ = new AtomicReference<QNode>(); in Phaser()
752 QNode node = new QNode(this, phase, true, false, 0L); in awaitAdvanceInterruptibly()
790 QNode node = new QNode(this, phase, true, true, nanos); in awaitAdvanceInterruptibly()
968 QNode q; // first element of queue in releaseWaiters()
970 AtomicReference<QNode> head = (phase & 1) == 0 ? evenQ : oddQ; in releaseWaiters()
991 AtomicReference<QNode> head = (phase & 1) == 0 ? evenQ : oddQ; in abortWait()
994 QNode q = head.get(); in abortWait()
[all …]
|