| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| ConcurrentLinkedQueue.java | 289 if (h != p && casHead(h, p))
[all...] |
| ConcurrentLinkedDeque.java | 372 casHead(h, newNode); // Failure is OK.
610 if (casHead(h, p))
754 || casHead(h, p))
[all...] |
| LinkedTransferQueue.java | 573 private boolean casHead(Node cmp, Node val) {
616 if (head == h && casHead(h, n == null ? q : n)) {
659 if (casHead(null, s))
[all...] |
| SynchronousQueue.java | 305 boolean casHead(SNode h, SNode nh) {
358 casHead(h, h.next); // pop cancelled node
361 } else if (casHead(h, s = snode(s, e, h, mode))) {
368 casHead(h, s.next); // help s's fulfiller
373 casHead(h, h.next); // pop and retry
374 else if (casHead(h, s=snode(s, e, h, FULFILLING|mode))) {
378 casHead(s, null); // pop fulfill node
384 casHead(s, mn); // pop both s and m
393 casHead(h, null); // pop fulfilling node
397 casHead(h, mn); // pop both h and
[all...] |
| ConcurrentSkipListMap.java | 403 private boolean casHead(HeadIndex<K,V> cmp, HeadIndex<K,V> val) {
[all...] |
| /prebuilts/misc/common/robolectric/lib/ |
| backport-util-concurrent-3.1.jar | |
| /prebuilts/tools/common/m2/repository/backport-util-concurrent/backport-util-concurrent/3.1/ |
| backport-util-concurrent-3.1.jar | |
| /prebuilts/tools/common/m2/repository/io/reactivex/rxjava/1.1.0/ |
| rxjava-1.1.0.jar | |
| /prebuilts/tools/common/m2/repository/io/reactivex/rxjava/1.1.3/ |
| rxjava-1.1.3.jar | |
| /prebuilts/tools/common/m2/repository/io/reactivex/rxjava/1.1.4/ |
| rxjava-1.1.4.jar | |
| /prebuilts/tools/common/m2/repository/io/reactivex/rxjava/1.1.5/ |
| rxjava-1.1.5.jar | |
| /prebuilts/tools/common/m2/repository/io/reactivex/rxjava/1.1.6/ |
| rxjava-1.1.6.jar | |
| /prebuilts/tools/common/m2/repository/io/reactivex/rxjava/1.2.3/ |
| rxjava-1.2.3.jar | |
