Searched refs:QNode (Results 1 – 2 of 2) sorted by relevance
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | SynchronousQueue.java | 536 static final class QNode { class in SynchronousQueue.TransferQueue
537 volatile QNode next; // next node in queue
542 QNode(Object item, boolean isData) { in QNode() method in SynchronousQueue.TransferQueue.QNode
547 boolean casNext(QNode cmp, QNode val) { in casNext()
585 (QNode.class.getDeclaredField("item"));
587 (QNode.class.getDeclaredField("next"));
595 transient volatile QNode head;
597 transient volatile QNode tail;
603 transient volatile QNode cleanMe;
606 QNode h = new QNode(null, false); // initialize to dummy node. in TransferQueue()
[all …]
|
| D | Phaser.java | 348 private final AtomicReference<QNode> evenQ;
349 private final AtomicReference<QNode> oddQ;
351 private AtomicReference<QNode> queueFor(int phase) { in queueFor()
563 this.evenQ = new AtomicReference<QNode>(); in Phaser()
564 this.oddQ = new AtomicReference<QNode>(); in Phaser()
753 QNode node = new QNode(this, phase, true, false, 0L); in awaitAdvanceInterruptibly()
791 QNode node = new QNode(this, phase, true, true, nanos); in awaitAdvanceInterruptibly()
969 QNode q; // first element of queue in releaseWaiters()
971 AtomicReference<QNode> head = (phase & 1) == 0 ? evenQ : oddQ; in releaseWaiters()
992 AtomicReference<QNode> head = (phase & 1) == 0 ? evenQ : oddQ; in abortWait()
[all …]
|