Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for resync (0.2 sec)

  1. android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       */
      abstract double coolDownIntervalMicros();
    
      /** Updates {@code storedPermits} and {@code nextFreeTicketMicros} based on the current time. */
      void resync(long nowMicros) {
        // if nextFreeTicket is in the past, resync to now
        if (nowMicros > nextFreeTicketMicros) {
          double newPermits = (nowMicros - nextFreeTicketMicros) / coolDownIntervalMicros();
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 19.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

                AbstractFuture<String> future = setFutureFuture.get();
                setFutureSetSuccess.set(currentFuture.get().setFuture(future));
                setFutureCompletionSuccess.set(future.set("hello-async-world"));
                awaitUnchecked(barrier);
              }
            };
        final Set<Object> finalResults = Collections.synchronizedSet(Sets.newIdentityHashSet());
        Runnable collectResultsRunnable =
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/ImmutableBiMap.java

       * as implementation details.
       *
       * <p>Since the bimap is immutable, ImmutableBiMap doesn't require special logic for keeping the
       * bimap and its inverse in sync during serialization, the way AbstractBiMap does.
       */
      @J2ktIncompatible // serialization
      private static class SerializedForm<K, V> extends ImmutableMap.SerializedForm<K, V> {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed May 01 18:44:57 GMT 2024
    - 22.4K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

                AbstractFuture<String> future = setFutureFuture.get();
                setFutureSetSuccess.set(currentFuture.get().setFuture(future));
                setFutureCompletionSuccess.set(future.set("hello-async-world"));
                awaitUnchecked(barrier);
              }
            };
        final Set<Object> finalResults = Collections.synchronizedSet(Sets.newIdentityHashSet());
        Runnable collectResultsRunnable =
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
Back to top