Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 78 for rollback (0.66 sec)

  1. android/guava/src/com/google/common/hash/Striped64.java

      /** Table of cells. When non-null, size is a power of 2. */
      @CheckForNull transient volatile Cell[] cells;
    
      /**
       * Base value, used mainly when there is no contention, but also as a fallback during table
       * initialization races. Updated via CAS.
       */
      transient volatile long base;
    
      /** Spinlock (locked via CAS) used when resizing and/or creating Cells. */
      transient volatile int busy;
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/primitives/UnsignedBytes.java

                && (BYTE_ARRAY_BASE_OFFSET % 8) == 0
                // sanity check - this should never fail
                && theUnsafe.arrayIndexScale(byte[].class) == 1)) {
              throw new Error(); // force fallback to PureJavaComparator
            }
          }
    
          /**
           * Returns a sun.misc.Unsafe. Suitable for use in a 3rd party package. Replace with a simple
           * call to Unsafe.getUnsafe when integrating into a jdk.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

      }
    
      /**
       * This tests for a bug where if {@link Service#stopAsync()} was called while the service was
       * {@link State#STARTING} more than once, the {@link Listener#stopping(State)} callback would get
       * called multiple times.
       */
      public void testManualServiceStopMultipleTimesWhileStarting() throws Exception {
        ManualSwitchedService service = new ManualSwitchedService();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 29.3K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

      }
    
      /**
       * This tests for a bug where if {@link Service#stopAsync()} was called while the service was
       * {@link State#STARTING} more than once, the {@link Listener#stopping(State)} callback would get
       * called multiple times.
       */
      public void testManualServiceStopMultipleTimesWhileStarting() throws Exception {
        ManualSwitchedService service = new ManualSwitchedService();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 29.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

            // Some Android 5.0.x Samsung devices have bugs in JDK reflection APIs that cause
            // getDeclaredField to throw a NoSuchFieldException when the field is definitely there.
            // For these users fallback to a suboptimal implementation, based on synchronized. This will
            // be a definite performance hit to those users.
            thrownAtomicReferenceFieldUpdaterFailure = atomicReferenceFieldUpdaterFailure;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractFuture.java

            // Some Android 5.0.x Samsung devices have bugs in JDK reflection APIs that cause
            // getDeclaredField to throw a NoSuchFieldException when the field is definitely there.
            // For these users fallback to a suboptimal implementation, based on synchronized. This will
            // be a definite performance hit to those users.
            thrownAtomicReferenceFieldUpdaterFailure = atomicReferenceFieldUpdaterFailure;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       *   <li>If an exception propagates out of a {@code Runnable}, it is not necessarily seen by any
       *       {@code UncaughtExceptionHandler} for the thread. For example, if the callback passed to
       *       {@link Futures#addCallback} throws an exception, that exception will be typically be
       *       logged by the {@link ListenableFuture} implementation, even if the thread is configured
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 39K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/cache/LocalCache.java

                }
                result.put(key, value);
              }
            } catch (UnsupportedLoadingOperationException e) {
              // loadAll not implemented, fallback to load
              for (K key : keysToLoad) {
                misses--; // get will count this miss
                result.put(key, get(key, defaultLoader));
              }
            }
          }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 143.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/Futures.java

       *
       * @param future The future attach the callback to.
       * @param callback The callback to invoke when {@code future} is completed.
       * @param executor The executor to run {@code callback} when the future completes.
       * @since 10.0
       */
      public static <V extends @Nullable Object> void addCallback(
          final ListenableFuture<V> future,
          final FutureCallback<? super V> callback,
          Executor executor) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 59.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       * java.util.concurrent.CompletableFuture#thenAcceptAsync}.
       *
       * @param callback The callback to invoke when this {@code Future} is completed.
       * @param executor The executor to run {@code callback} when the future completes.
       */
      public final void addCallback(FutureCallback<? super V> callback, Executor executor) {
        Futures.addCallback(this, callback, executor);
      }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 11 19:08:44 UTC 2023
    - 18.7K bytes
    - Viewed (0)
Back to top