| /libcore/luni/src/main/java/java/util/concurrent/ |
| FutureTask.java | 44 * AtomicXFieldUpdaters and instead directly use Unsafe intrinsics.
137 UNSAFE.compareAndSwapInt(this, stateOffset, NEW,
147 UNSAFE.putOrderedInt(this, stateOffset, INTERRUPTED);
201 if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) {
203 UNSAFE.putOrderedInt(this, stateOffset, NORMAL); // final state
219 if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) {
221 UNSAFE.putOrderedInt(this, stateOffset, EXCEPTIONAL); // final state
228 !UNSAFE.compareAndSwapObject(this, runnerOffset,
270 !UNSAFE.compareAndSwapObject(this, runnerOffset,
338 if (UNSAFE.compareAndSwapObject(this, waitersOffset, q, null))
[all...] |
| LinkedTransferQueue.java | 416 * them after use. Relies heavily on Unsafe mechanics to minimize
428 return UNSAFE.compareAndSwapObject(this, nextOffset, cmp, val);
433 return UNSAFE.compareAndSwapObject(this, itemOffset, cmp, val);
441 UNSAFE.putObject(this, itemOffset, item); // relaxed write
450 UNSAFE.putObject(this, nextOffset, this);
463 UNSAFE.putObject(this, itemOffset, this);
464 UNSAFE.putObject(this, waiterOffset, null);
509 // Unsafe mechanics
510 private static final sun.misc.Unsafe UNSAFE;
[all...] |
| Exchanger.java | 210 * heavily dependent on intrinsics (Unsafe) to use inlined
603 // Unsafe mechanics
604 private static final sun.misc.Unsafe U;
613 U = sun.misc.Unsafe.getUnsafe();
|
| Phaser.java | 364 if (UNSAFE.compareAndSwapLong(this, stateOffset, s, s-=adjust)) {
377 UNSAFE.compareAndSwapLong(this, stateOffset, s, n);
382 UNSAFE.compareAndSwapLong(this, stateOffset,
418 else if (UNSAFE.compareAndSwapLong(this, stateOffset,
425 if (UNSAFE.compareAndSwapLong(this, stateOffset, s, next))
437 while (!UNSAFE.compareAndSwapLong
469 !UNSAFE.compareAndSwapLong
659 if (UNSAFE.compareAndSwapLong(this, stateOffset, s,
675 if (!UNSAFE.compareAndSwapLong(this, stateOffset, s, n))
[all...] |
| ConcurrentLinkedDeque.java | 277 UNSAFE.putObject(this, itemOffset, item);
281 return UNSAFE.compareAndSwapObject(this, itemOffset, cmp, val);
285 UNSAFE.putOrderedObject(this, nextOffset, val);
289 return UNSAFE.compareAndSwapObject(this, nextOffset, cmp, val);
293 UNSAFE.putOrderedObject(this, prevOffset, val);
297 return UNSAFE.compareAndSwapObject(this, prevOffset, cmp, val);
300 // Unsafe mechanics
302 private static final sun.misc.Unsafe UNSAFE;
309 UNSAFE = sun.misc.Unsafe.getUnsafe()
[all...] |
| PriorityBlockingQueue.java | 253 UNSAFE.compareAndSwapInt(this, allocationSpinLockOffset,
909 // Unsafe mechanics
910 private static final sun.misc.Unsafe UNSAFE;
914 UNSAFE = sun.misc.Unsafe.getUnsafe();
916 allocationSpinLockOffset = UNSAFE.objectFieldOffset
|
| ConcurrentHashMap.java | 81 * which is done via Unsafe within methods segmentAt etc
190 UNSAFE.putOrderedObject(this, nextOffset, n);
193 // Unsafe mechanics
194 static final sun.misc.Unsafe UNSAFE;
198 UNSAFE = sun.misc.Unsafe.getUnsafe();
200 nextOffset = UNSAFE.objectFieldOffset
216 (HashEntry<K,V>) UNSAFE.getObjectVolatile
226 UNSAFE.putOrderedObject(tab, ((long)i << TSHIFT) + TBASE, e)
[all...] |
| ConcurrentSkipListMap.java | 353 return UNSAFE.compareAndSwapObject(this, headOffset, cmp, val);
396 return UNSAFE.compareAndSwapObject(this, valueOffset, cmp, val);
403 return UNSAFE.compareAndSwapObject(this, nextOffset, cmp, val);
482 // UNSAFE mechanics
484 private static final sun.misc.Unsafe UNSAFE;
490 UNSAFE = sun.misc.Unsafe.getUnsafe();
492 valueOffset = UNSAFE.objectFieldOffset
494 nextOffset = UNSAFE.objectFieldOffse
[all...] |
| ForkJoinTask.java | [all...] |
| ForkJoinPool.java | 575 * Implementation relies heavily on "Unsafe" intrinsics
599 * volatiles/atomics provided by Unsafe. Insertions must in
604 * Unsafe array operations, all accesses perform explicit null
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| AbstractQueuedLongSynchronizer.java | 12 import sun.misc.Unsafe;
315 return unsafe.compareAndSwapLong(this, stateOffset, expect, update);
2010 private static final Unsafe unsafe = Unsafe.getUnsafe(); field in class:AbstractQueuedLongSynchronizer
[all...] |
| AbstractQueuedSynchronizer.java | 12 import sun.misc.Unsafe;
545 return unsafe.compareAndSwapInt(this, stateOffset, expect, update);
2238 private static final Unsafe unsafe = Unsafe.getUnsafe(); field in class:AbstractQueuedSynchronizer
[all...] |
