Searched refs:casHead (Results 1 - 5 of 5) sorted by relevance
/openjdk7/jdk/src/share/classes/java/util/concurrent/ |
H A D | SynchronousQueue.java | 303 boolean casHead(SNode h, SNode nh) { method in class:SynchronousQueue.TransferStack 355 casHead(h, h.next); // pop cancelled node 358 } else if (casHead(h, s = snode(s, e, h, mode))) { 365 casHead(h, s.next); // help s's fulfiller 370 casHead(h, h.next); // pop and retry 371 else if (casHead(h, s=snode(s, e, h, FULFILLING|mode))) { 375 casHead(s, null); // pop fulfill node 381 casHead(s, mn); // pop both s and m 390 casHead(h, null); // pop fulfilling node 394 casHead( [all...] |
H A D | LinkedTransferQueue.java | 572 private boolean casHead(Node cmp, Node val) { method in class:LinkedTransferQueue 621 if (head == h && casHead(h, n == null ? q : n)) { 663 if (casHead(null, s)) 946 if (hn != h && casHead(h, hn))
|
H A D | ConcurrentLinkedQueue.java | 304 if (h != p && casHead(h, p)) 814 private boolean casHead(Node<E> cmp, Node<E> val) { method in class:ConcurrentLinkedQueue
|
H A D | ConcurrentLinkedDeque.java | 376 casHead(h, newNode); // Failure is OK. 615 if (casHead(h, p)) 759 || casHead(h, p)) 1440 private boolean casHead(Node<E> cmp, Node<E> val) { method in class:ConcurrentLinkedDeque
|
H A D | ConcurrentSkipListMap.java | 381 private boolean casHead(HeadIndex<K,V> cmp, HeadIndex<K,V> val) { method in class:ConcurrentSkipListMap 954 if (casHead(oldh, newh)) { 1118 casHead(h, d) && // try to set 1120 casHead(d, h); // try to backout
|
Completed in 282 milliseconds