HomeSort by relevance Sort by last modified time
    Searched refs:compareAndSet (Results 1 - 25 of 64) sorted by null

1 2 3

  /external/droiddriver/src/io/appium/droiddriver/helpers/
SingleRun.java 35 if (hasRun.compareAndSet(false, true)) {
  /external/guava/guava/src/com/google/common/util/concurrent/
AtomicDouble.java 32 * values in methods such as {@link #compareAndSet} by comparing their
131 public final boolean compareAndSet(double expect, double update) {
132 return updater.compareAndSet(this,
146 * appropriate alternative to {@code compareAndSet}.
170 if (updater.compareAndSet(this, current, next)) {
188 if (updater.compareAndSet(this, current, next)) {
AtomicDoubleArray.java 27 * values in methods such as {@link #compareAndSet} by comparing their
143 public final boolean compareAndSet(int i, double expect, double update) {
144 return longs.compareAndSet(i,
159 * appropriate alternative to {@code compareAndSet}.
185 if (longs.compareAndSet(i, current, next)) {
204 if (longs.compareAndSet(i, current, next)) {
AtomicLongMap.java 118 // don't compareAndSet a zero
127 if (atomic.compareAndSet(oldValue, newValue)) {
167 // don't compareAndSet a zero
176 if (atomic.compareAndSet(oldValue, newValue)) {
202 // don't compareAndSet a zero
210 if (atomic.compareAndSet(oldValue, newValue)) {
242 if (oldValue == 0L || atomic.compareAndSet(oldValue, 0L)) {
377 // don't compareAndSet a zero
402 return (atomic == null) ? false : atomic.compareAndSet(expectedOldValue, newValue);
421 if (oldValue == 0L || atomic.compareAndSet(oldValue, 0L))
    [all...]
JdkFutureAdapters.java 152 if (hasListeners.compareAndSet(false, true)) {
  /external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/internal/
CurrentState.java 85 currentInternalState.compareAndSet(
118 if (!currentInternalState.compareAndSet(
  /external/guava/guava-tests/test/com/google/common/util/concurrent/
AtomicDoubleTest.java 97 * compareAndSet succeeds in changing value if equal to expected else fails
105 assertFalse(at.compareAndSet(unused, x));
107 assertTrue(at.compareAndSet(prev, x));
114 * compareAndSet in one thread enables another waiting for value
122 while (!at.compareAndSet(2.0, 3.0)) {
127 assertTrue(at.compareAndSet(1.0, 2.0));
272 * compareAndSet treats +0.0 and -0.0 as distinct values
276 assertFalse(at.compareAndSet(-0.0, 7.0));
279 assertTrue(at.compareAndSet(+0.0, -0.0));
281 assertFalse(at.compareAndSet(+0.0, 7.0))
    [all...]
AtomicDoubleArrayTest.java 131 aa.compareAndSet(index, 1.0, 2.0);
178 * compareAndSet succeeds in changing value if equal to expected else fails
187 assertFalse(aa.compareAndSet(i, unused, x));
189 assertTrue(aa.compareAndSet(i, prev, x));
197 * compareAndSet in one thread enables another waiting for value
206 while (!a.compareAndSet(0, 2.0, 3.0)) {
211 assertTrue(a.compareAndSet(0, 1.0, 2.0));
300 if (aa.compareAndSet(i, v, v - 1.0)) {
367 * compareAndSet treats +0.0 and -0.0 as distinct values
372 assertFalse(aa.compareAndSet(i, -0.0, 7.0))
    [all...]
  /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/
AltsHandshakerStub.java 89 AltsHandshakerStub.this.exceptionMessage.compareAndSet(
98 AltsHandshakerStub.this.exceptionMessage.compareAndSet(
108 AltsHandshakerStub.this.exceptionMessage.compareAndSet(null, "Response stream closed.");
  /external/guava/guava-gwt/src-super/java/util/super/java/util/concurrent/atomic/
AtomicInteger.java 54 public final boolean compareAndSet(int expect, int update) {
AtomicLong.java 54 public final boolean compareAndSet(long expect, long update) {
  /art/test/954-invoke-polymorphic-verifier/smali/
VarHandleUnhappyAccessors.smali 31 invoke-static {v0}, LVarHandleUnhappyAccessors;->compareAndSet(Ljava/lang/invoke/VarHandle;)V
54 .method public static compareAndSet(Ljava/lang/invoke/VarHandle;)V
57 invoke-polymorphic {p0, v0}, Ljava/lang/invoke/VarHandle;->compareAndSet(I)Z, ([Ljava/lang/Object;)Ljava/lang/Object;
  /external/guava/guava/src/com/google/common/cache/
Striped64.java 104 return valueUpdater.compareAndSet(this, cmp, val);
153 return baseUpdater.compareAndSet(this, cmp, val);
160 return busyUpdater.compareAndSet(this, 0, 1);
  /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/
RealWebSocket.java 170 if (connectionClosed.compareAndSet(false, true)) {
190 if (connectionClosed.compareAndSet(false, true)) {
210 if (connectionClosed.compareAndSet(false, true)) {
  /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
TestClientStreamTracer.java 157 if (!outboundHeadersCalled.compareAndSet(null, new Exception("first stack"))
168 if (!inboundHeadersCalled.compareAndSet(null, new Exception("first stack"))
TestServerStreamTracer.java 136 if (!serverCallInfo.compareAndSet(null, callInfo) && delegate.failDuplicateCallbacks.get()) {
  /cts/tests/app/app/src/android/app/stubs/
OrientationTestUtils.java 80 assertTrue(mLatch.compareAndSet(null, latch));
  /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
AtomicBackoff.java 66 boolean swapped = value.compareAndSet(savedValue, newValue);
  /external/libtextclassifier/java/com/google/android/textclassifier/
LangIdModel.java 59 if (isClosed.compareAndSet(false, true)) {
  /art/test/712-varhandle-invocations/src/
VarHandleAccessorExceptionTests.java 145 vh.compareAndSet(this, 33, 44);
148 updated = (boolean) vh.compareAndSet(this, 44);
VarHandleBadCoordinateTests.java 47 vh.compareAndSet(new A(), (byte) 0, (byte) 3);
48 vh.compareAndSet(new B(), (byte) 0, (byte) 3);
50 vh.compareAndSet(new C(), (byte) 0, (byte) 3);
55 vh.compareAndSet(0xbad0bad0, (byte) 0, (byte) 3);
60 vh.compareAndSet(0xbad0bad0, (byte) 0, Integer.MAX_VALUE);
65 vh.compareAndSet(0xbad0bad0, (byte) 0);
70 vh.compareAndSet(new A(), (byte) 0, Integer.MAX_VALUE);
75 vh.compareAndSet((A) null, (byte) 0, (byte) 3);
311 vh.compareAndSet(bytes, i, 767, 321);
658 vh.compareAndSet(buffer, i, 767, 321)
    [all...]
  /external/apache-commons-compress/src/main/java/org/apache/commons/compress/utils/
FixedLengthBlockOutputStream.java 185 if (closed.compareAndSet(false, true)) {
263 if (closed.compareAndSet(false, true)) {
  /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/
ManualFlowControlServer.java 59 if (serverCallStreamObserver.isReady() && wasReady.compareAndSet(false, true)) {
  /art/runtime/mirror/
var_handle_test.cc 343 // Check compatibility - "CompareAndSet" pattern
379 Handle<MethodType> compareAndSet = hs.NewHandle(MethodTypeOf("(Ljava/lang/Integer;II)Z"));
394 EXPECT_TRUE(test_mode(VarHandle::AccessMode::kCompareAndSet, compareAndSet));
398 EXPECT_TRUE(test_mode(VarHandle::AccessMode::kWeakCompareAndSetPlain, compareAndSet));
399 EXPECT_TRUE(test_mode(VarHandle::AccessMode::kWeakCompareAndSet, compareAndSet));
400 EXPECT_TRUE(test_mode(VarHandle::AccessMode::kWeakCompareAndSetAcquire, compareAndSet));
401 EXPECT_TRUE(test_mode(VarHandle::AccessMode::kWeakCompareAndSetRelease, compareAndSet));
485 // Check compatibility - "CompareAndSet" pattern
517 Handle<MethodType> compareAndSet = hs.NewHandle(MethodTypeOf("(II)Z"));
532 EXPECT_TRUE(test_mode(VarHandle::AccessMode::kCompareAndSet, compareAndSet));
    [all...]
  /external/guava/guava/src/com/google/common/collect/
ConcurrentHashMultiset.java 63 * AtomicInteger results in zero, we compareAndSet the value to zero; if that succeeds, we remove
233 if (existingCounter.compareAndSet(oldValue, newValue)) {
290 if (existingCounter.compareAndSet(oldValue, newValue)) {
331 if (existingCounter.compareAndSet(oldValue, newValue)) {
380 if (existingCounter.compareAndSet(oldValue, count)) {
433 if (existingCounter.compareAndSet(oldValue, newCount)) {

Completed in 500 milliseconds

1 2 3