| /art/test/067-preemptive-unpark/src/ |
| Main.java | 1 import sun.misc.Unsafe;
6 private static Unsafe UNSAFE;
16 UNSAFE.unpark(test);
40 * Set up {@link #UNSAFE}.
44 * Subvert the access check to get the unique Unsafe instance.
49 Field field = Unsafe.class.getDeclaredField("THE_ONE");
52 UNSAFE = (Unsafe) field.get(null);
95 UNSAFE.park(false, 500 * 1000000); // 500 mse
[all...] |
| /dalvik/tests/067-preemptive-unpark/src/ |
| Main.java | 1 import sun.misc.Unsafe;
6 private static Unsafe UNSAFE;
16 UNSAFE.unpark(test);
40 * Set up {@link #UNSAFE}.
44 * Subvert the access check to get the unique Unsafe instance.
49 Field field = Unsafe.class.getDeclaredField("THE_ONE");
52 UNSAFE = (Unsafe) field.get(null);
95 UNSAFE.park(false, 500 * 1000000); // 500 mse
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ConcurrentLinkedQueue.java | 136 * for a volatile write to item by using Unsafe.putObject instead
157 UNSAFE.putObject(this, itemOffset, item);
161 return UNSAFE.compareAndSwapObject(this, itemOffset, cmp, val);
165 UNSAFE.putOrderedObject(this, nextOffset, val);
169 return UNSAFE.compareAndSwapObject(this, nextOffset, cmp, val);
172 // Unsafe mechanics
174 private static final sun.misc.Unsafe UNSAFE;
180 UNSAFE = sun.misc.Unsafe.getUnsafe()
[all...] |
| ConcurrentSkipListSet.java | 446 UNSAFE.putObjectVolatile(this, mapOffset, map);
449 private static final sun.misc.Unsafe UNSAFE;
453 UNSAFE = sun.misc.Unsafe.getUnsafe();
455 mapOffset = UNSAFE.objectFieldOffset
|
| 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...] |
| 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...] |
| 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...] |
| 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...] |
| 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...] |
| SynchronousQueue.java | 217 UNSAFE.compareAndSwapObject(this, nextOffset, cmp, val);
230 UNSAFE.compareAndSwapObject(this, matchOffset, null, s)) {
245 UNSAFE.compareAndSwapObject(this, matchOffset, null, this);
252 // Unsafe mechanics
253 private static final sun.misc.Unsafe UNSAFE;
259 UNSAFE = sun.misc.Unsafe.getUnsafe();
261 matchOffset = UNSAFE.objectFieldOffset
263 nextOffset = UNSAFE.objectFieldOffse
[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
|
| 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...] |
| /libcore/luni/src/main/java/java/util/concurrent/atomic/ |
| AtomicMarkableReference.java | 162 // Unsafe mechanics
164 private static final sun.misc.Unsafe UNSAFE = sun.misc.Unsafe.getUnsafe();
166 objectFieldOffset(UNSAFE, "pair", AtomicMarkableReference.class);
169 return UNSAFE.compareAndSwapObject(this, pairOffset, cmp, val);
172 static long objectFieldOffset(sun.misc.Unsafe UNSAFE,
175 return UNSAFE.objectFieldOffset(klazz.getDeclaredField(field));
|
| AtomicStampedReference.java | 162 // Unsafe mechanics
164 private static final sun.misc.Unsafe UNSAFE = sun.misc.Unsafe.getUnsafe();
166 objectFieldOffset(UNSAFE, "pair", AtomicStampedReference.class);
169 return UNSAFE.compareAndSwapObject(this, pairOffset, cmp, val);
172 static long objectFieldOffset(sun.misc.Unsafe UNSAFE,
175 return UNSAFE.objectFieldOffset(klazz.getDeclaredField(field));
|
| /libcore/luni/src/test/java/tests/api/org/apache/harmony/kernel/dalvik/ |
| ThreadsTest.java | 24 import sun.misc.Unsafe;
27 * Tests for the <code>park()</code> functionality of {@link Unsafe}.
30 private static Unsafe UNSAFE = null;
33 * Set up {@link #UNSAFE}. This subverts the access check to
34 * get the unique Unsafe instance. We can do this because
39 Field field = Unsafe.class.getDeclaredField("THE_ONE");
42 UNSAFE = (Unsafe) field.get(null);
86 UNSAFE.unpark(parkerThread)
[all...] |
| /external/droiddriver/libs/ |
| guava-13.0.jar | |
| /prebuilts/devtools/tools/lib/ |
| guava-13.0.1.jar | |
| /prebuilts/tools/common/gradle-plugins/repository/com/google/guava/guava/14.0/ |
| guava-14.0.jar | |
| /prebuilts/tools/common/guava-tools/ |
| guava-13.0.1.jar | |
| /prebuilts/tools/common/m2/repository/com/google/guava/guava/13.0.1/ |
| guava-13.0.1.jar | |
