Home
last modified time | relevance | path

Searched refs:AtomicLong (Results 1 – 25 of 77) sorted by relevance

1234

/external/guava/android/guava/src/com/google/common/util/concurrent/
DAtomicLongMap.java30 import java.util.concurrent.atomic.AtomicLong;
58 private final ConcurrentHashMap<K, AtomicLong> map;
60 private AtomicLongMap(ConcurrentHashMap<K, AtomicLong> map) { in AtomicLongMap()
66 return new AtomicLongMap<K>(new ConcurrentHashMap<K, AtomicLong>()); in create()
81 AtomicLong atomic = map.get(key); in get()
109 AtomicLong atomic = map.get(key); in addAndGet()
111 atomic = map.putIfAbsent(key, new AtomicLong(delta)); in addAndGet()
122 if (map.replace(key, atomic, new AtomicLong(delta))) { in addAndGet()
162 AtomicLong atomic = map.get(key); in getAndAdd()
164 atomic = map.putIfAbsent(key, new AtomicLong(delta)); in getAndAdd()
[all …]
DAtomicDouble.java21 import java.util.concurrent.atomic.AtomicLong;
56 private transient AtomicLong value;
64 value = new AtomicLong(doubleToRawLongBits(initialValue)); in AtomicDouble()
238 value = new AtomicLong(); in readObject()
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DTestStreamTracer.java25 import java.util.concurrent.atomic.AtomicLong;
90 protected final AtomicLong outboundWireSize = new AtomicLong();
91 protected final AtomicLong inboundWireSize = new AtomicLong();
92 protected final AtomicLong outboundUncompressedSize = new AtomicLong();
93 protected final AtomicLong inboundUncompressedSize = new AtomicLong();
/external/snakeyaml/src/test/java/org/yaml/snakeyaml/constructor/
DAtomicJavaBean.java18 import java.util.concurrent.atomic.AtomicLong;
22 private AtomicLong atomic;
32 public AtomicLong getAtomic() { in getAtomic()
36 public void setAtomic(AtomicLong atomic) { in setAtomic()
/external/guava/guava-tests/benchmark/com/google/common/cache/
DLoadingCacheSingleThreadBenchmark.java25 import java.util.concurrent.atomic.AtomicLong;
53 static AtomicLong requests = new AtomicLong(0);
54 static AtomicLong misses = new AtomicLong(0);
/external/guava/android/guava-tests/benchmark/com/google/common/cache/
DLoadingCacheSingleThreadBenchmark.java25 import java.util.concurrent.atomic.AtomicLong;
53 static AtomicLong requests = new AtomicLong(0);
54 static AtomicLong misses = new AtomicLong(0);
/external/junit/src/main/java/org/junit/runner/
DResult.java14 import java.util.concurrent.atomic.AtomicLong;
33 private final AtomicLong runTime;
34 private final AtomicLong startTime;
44 runTime = new AtomicLong(); in Result()
45 startTime = new AtomicLong(); in Result()
53 runTime = new AtomicLong(serializedForm.fRunTime); in Result()
54 startTime = new AtomicLong(serializedForm.fStartTime); in Result()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAtomicLongCounter.java19 import java.util.concurrent.atomic.AtomicLong;
25 private final AtomicLong counter = new AtomicLong();
DAtomicBackoff.java20 import java.util.concurrent.atomic.AtomicLong;
33 private final AtomicLong value = new AtomicLong();
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DInternalLogId.java19 import java.util.concurrent.atomic.AtomicLong;
28 private static final AtomicLong idAlloc = new AtomicLong();
/external/kotlinx.atomicfu/atomicfu/src/commonMain/kotlin/kotlinx/atomicfu/
DAtomicFU.common.kt40 public expect fun atomic(initial: Long): AtomicLong in atomic()
321 public expect class AtomicLong { class
386 public inline fun AtomicLong.loop(action: (Long) -> Unit): Nothing { in lazySet()
395 public inline fun AtomicLong.update(function: (Long) -> Long) { in update()
406 public inline fun AtomicLong.getAndUpdate(function: (Long) -> Long): Long { in getAndUpdate()
417 public inline fun AtomicLong.updateAndGet(function: (Long) -> Long): Long { in updateAndGet()
448 public operator fun get(index: Int): AtomicLong = array[index] in get()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/
DChannelLFStressTest.kt9 import java.util.concurrent.atomic.AtomicLong
28 private val sendIndex = AtomicLong()
29 private val receiveCount = AtomicLong()
30 private val duplicateCount = AtomicLong()
DBroadcastChannelMultiReceiveStressTest.kt34 private val sentTotal = AtomicLong() in <lambda>()
35 private val receivedTotal = AtomicLong() in <lambda>()
36 private val stopOnReceive = AtomicLong(-1) in <lambda>()
37 private val lastReceived = Array(nReceivers) { AtomicLong(-1) } in <lambda>()
/external/guava/android/guava-testlib/src/com/google/common/testing/
DFakeTicker.java25 import java.util.concurrent.atomic.AtomicLong;
42 private final AtomicLong nanos = new AtomicLong();
/external/caliper/caliper/src/main/java/com/google/caliper/worker/
DAggregateAllocationsRecorder.java23 import java.util.concurrent.atomic.AtomicLong;
32 private final AtomicLong allocationSize = new AtomicLong();
/external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/source/
DLoadEventInfo.java24 import java.util.concurrent.atomic.AtomicLong;
30 private static final AtomicLong idSource = new AtomicLong();
/external/guava/guava-tests/test/com/google/common/primitives/
DImmutableLongArrayTest.java38 import java.util.concurrent.atomic.AtomicLong;
170 AtomicLong counter = new AtomicLong(0); in testBuilder_bruteForce()
185 void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) { in doIt()
191 void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) { in doIt()
201 void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) { in doIt()
212 void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) { in doIt()
223 void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) { in doIt()
233 void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) { in doIt()
243 void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) { in doIt()
259 abstract void doIt(ImmutableLongArray.Builder builder, AtomicLong counter); in doIt()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/internal/
DLockFreeLinkedListAtomicLFStressTest.kt11 import java.util.concurrent.atomic.AtomicLong in <lambda>()
32 private val undone = AtomicLong() in <lambda>()
33 private val missed = AtomicLong() in <lambda>()
34 private val removed = AtomicLong() in <lambda>()
36 private val index = AtomicLong() in <lambda>()
/external/guava/guava-testlib/src/com/google/common/testing/
DFakeTicker.java26 import java.util.concurrent.atomic.AtomicLong;
43 private final AtomicLong nanos = new AtomicLong();
/external/kotlinx.atomicfu/atomicfu/src/jvmMain/kotlin/kotlinx/atomicfu/
DInterceptor.kt32 open fun beforeUpdate(ref: AtomicLong) {} in beforeUpdate()
36 open fun afterSet(ref: AtomicLong, newValue: Long) {} in afterSet()
40 open fun afterRMW(ref: AtomicLong, oldValue: Long, newValue: Long) {} in afterRMW()
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DBinaryLogProviderImpl.java24 import java.util.concurrent.atomic.AtomicLong;
32 private static final AtomicLong counter = new AtomicLong(1);
/external/okhttp/okhttp-ws-tests/src/main/java/com/squareup/okhttp/ws/
DAutobahnTester.java29 import java.util.concurrent.atomic.AtomicLong;
72 final AtomicLong startNanos = new AtomicLong(); in runTest()
133 final AtomicLong countRef = new AtomicLong(); in getTestCount()
/external/jackson-databind/src/main/java/com/fasterxml/jackson/databind/ser/std/
DStdJdkSerializers.java41 sers.put(AtomicLong.class, AtomicLongSerializer.class); in all()
117 extends StdScalarSerializer<AtomicLong>
119 public AtomicLongSerializer() { super(AtomicLong.class, false); } in AtomicLongSerializer()
122 …public void serialize(AtomicLong value, JsonGenerator gen, SerializerProvider provider) throws IOE… in serialize()
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
DUnaryCallQpsBenchmark.java20 import java.util.concurrent.atomic.AtomicLong;
44 private static AtomicLong callCounter;
78 callCounter = new AtomicLong(); in setup()
DUnaryCallResponseBandwidthBenchmark.java20 import java.util.concurrent.atomic.AtomicLong;
49 private static AtomicLong callCounter;
84 callCounter = new AtomicLong(); in setup()

1234