Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 251 for ready (0.34 sec)

  1. guava/src/com/google/common/util/concurrent/ServiceManager.java

        @GuardedBy("monitor")
        final IdentityHashMap<Service, Stopwatch> startupTimers = new IdentityHashMap<>();
    
        /**
         * These two booleans are used to mark the state as ready to start.
         *
         * <p>{@link #ready}: is set by {@link #markReady} to indicate that all listeners have been
         * correctly installed
         *
         * <p>{@link #transitioned}: is set by {@link #transitionService} to indicate that some
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:41:16 UTC 2024
    - 33K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/hash/AbstractStreamingHasher.java

    import java.nio.ByteBuffer;
    import java.nio.ByteOrder;
    
    /**
     * A convenience base class for implementors of {@code Hasher}; handles accumulating data until an
     * entire "chunk" (of implementation-dependent length) is ready to be hashed.
     *
     * @author Kevin Bourrillion
     * @author Dimitris Andreou
     */
    // TODO(kevinb): this class still needs some design-and-document-for-inheritance love
    @ElementTypesAreNonnullByDefault
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Jun 15 20:59:00 UTC 2022
    - 7.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/io/CharSequenceReader.java

          target.put(seq.charAt(pos++));
        }
        return charsToRead;
      }
    
      @Override
      public synchronized int read() throws IOException {
        checkOpen();
        requireNonNull(seq); // safe because of checkOpen
        return hasRemaining() ? seq.charAt(pos++) : -1;
      }
    
      @Override
      public synchronized int read(char[] cbuf, int off, int len) throws IOException {
        checkPositionIndexes(off, off + len, cbuf.length);
        checkOpen();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 28 20:13:02 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/io/CharSequenceReader.java

          target.put(seq.charAt(pos++));
        }
        return charsToRead;
      }
    
      @Override
      public synchronized int read() throws IOException {
        checkOpen();
        requireNonNull(seq); // safe because of checkOpen
        return hasRemaining() ? seq.charAt(pos++) : -1;
      }
    
      @Override
      public synchronized int read(char[] cbuf, int off, int len) throws IOException {
        checkPositionIndexes(off, off + len, cbuf.length);
        checkOpen();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 28 20:13:02 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  5. guava/src/com/google/common/hash/AbstractCompositeHashFunction.java

        }
        this.functions = functions;
      }
    
      /**
       * Constructs a {@code HashCode} from the {@code Hasher} objects of the functions. Each of them
       * has consumed the entire input and they are ready to output a {@code HashCode}. The order of the
       * hashers are the same order as the functions given to the constructor.
       */
      // this could be cleaner if it passed HashCode[], but that would create yet another array...
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Oct 06 00:47:57 UTC 2021
    - 5.4K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

      }
    
      public void testSimpleWithWait() {
        RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
        limiter.acquire(); // R0.00
        stopwatch.sleepMillis(200); // U0.20, we are ready for the next request...
        limiter.acquire(); // R0.00, ...which is granted immediately
        limiter.acquire(); // R0.20
        assertEvents("R0.00", "U0.20", "R0.00", "R0.20");
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 21.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

      }
    
      public void testSimpleWithWait() {
        RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
        limiter.acquire(); // R0.00
        stopwatch.sleepMillis(200); // U0.20, we are ready for the next request...
        limiter.acquire(); // R0.00, ...which is granted immediately
        limiter.acquire(); // R0.20
        assertEvents("R0.00", "U0.20", "R0.00", "R0.20");
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 21.6K bytes
    - Viewed (0)
  8. CONTRIBUTING.md

    Due to Guava's nature as a subset of Google's internal codebase which is
    automatically synced to the public GitHub repository, we are unable to merge
    pull requests directly into the master branch. Instead, once a pull request is
    ready for merging, we'll make the appropriate changes in the internal codebase
    and, when the change is synced out, give the pull request author credit for the
    commit.
    
    Contributor License Agreement
    -----------------------------
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Nov 17 18:47:47 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  9. guava/src/com/google/common/eventbus/EventBus.java

     *   <li>It doesn't offer a way to wait for multiple events before taking action. For example, it
     *       doesn't offer a way to wait for multiple producers to all report that they're "ready," nor
     *       does it offer a way to batch multiple events from a single producer together.
     *   <li>It doesn't support backpressure and other features needed for resilience.
     *   <li>It doesn't provide much control of threading.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jul 17 16:01:41 UTC 2023
    - 12.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * translates to "almost empty buffers", which can be filled immediately.
       *
       * On the other hand, past underutilization could mean that "the server responsible for handling
       * the request has become less ready for future requests", i.e. its caches become stale, and
       * requests become more likely to trigger expensive operations (a more extreme case of this
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 19.3K bytes
    - Viewed (0)
Back to top