Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 531 - 540 of 659 for consumer (0.06 seconds)

  1. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        }
      }
    
      /** Wait for the given thread to reach the {@link State#TIMED_WAITING} thread state. */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void awaitTimedWaiting(Thread thread) {
        while (true) {
          switch (thread.getState()) {
            case BLOCKED:
            case NEW:
            case RUNNABLE:
            case WAITING:
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        }
      }
    
      /** Wait for the given thread to reach the {@link State#TIMED_WAITING} thread state. */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void awaitTimedWaiting(Thread thread) {
        while (true) {
          switch (thread.getState()) {
            case BLOCKED:
            case NEW:
            case RUNNABLE:
            case WAITING:
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/base/Verify.java

        if (reference == null) {
          throw new VerifyException(lenientFormat(errorMessageTemplate, errorMessageArgs));
        }
        return reference;
      }
    
      // TODO(kevinb): consider <T> T verifySingleton(Iterable<T>) to take over for
      // Iterables.getOnlyElement()
    
      private Verify() {}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Dec 29 17:36:00 GMT 2025
    - 18.5K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractService.java

     * requests, responding to them with {@link #notifyStarted()} and {@link #notifyStopped()}
     * callbacks. Its subclasses must manage threads manually; consider {@link
     * AbstractExecutionThreadService} if you need only a single execution thread.
     *
     * @author Jesse Wilson
     * @author Luke Sandberg
     * @since 1.0
     */
    @GwtIncompatible
    @J2ktIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  5. CHANGELOG/CHANGELOG-1.36.md

    - Promoted the `DRAAdminAccess` feature gate to GA. ([#137373](https://github.com/kubernetes/kubernetes/pull/137373),...
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Mar 19 23:38:00 GMT 2026
    - 142.1K bytes
    - Click Count (0)
  6. src/bytes/buffer.go

    }
    
    // ReadRune reads and returns the next UTF-8-encoded
    // Unicode code point from the buffer.
    // If no bytes are available, the error returned is io.EOF.
    // If the bytes are an erroneous UTF-8 encoding, it
    // consumes one byte and returns U+FFFD, 1.
    func (b *Buffer) ReadRune() (r rune, size int, err error) {
    	if b.empty() {
    		// Buffer is empty, reset to recover space.
    		b.Reset()
    		return 0, 0, io.EOF
    	}
    	c := b.buf[b.off]
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

      }
    
      /**
       * Reserves the given number of permits from this {@code RateLimiter} for future use, returning
       * the number of microseconds until the reservation can be consumed.
       *
       * @return time in microseconds to wait until the resource can be acquired, never negative
       */
      final long reserve(int permits) {
        checkPermits(permits);
        synchronized (mutex()) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:05:27 GMT 2025
    - 21.8K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/Futures.java

      // 'inputFuture'. That field is non-final and non-volatile. There are 2 places where the
      // 'inputFuture' field is read and where we will have to consider visibility of the write
      // operation in the constructor.
      //
      // 1. In the listener that performs the callback. In this case it is fine since inputFuture is
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  9. impl/maven-core/plugin-manager.txt

    To create the packaging for a plugin a special Maven packaging would be created with an accompanying life-cycle in order to create the plugin metadata required and create an archive of the plugin that can be consumed at runtime.
    
    h3. Creation of an isolated classloader
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jan 22 11:03:29 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/base/Preconditions.java

     *
     * <p>The message string is not formatted unless the exception will be thrown, so the cost of the
     * string formatting itself should not be a concern.
     *
     * <p>As with any performance concerns, you should consider profiling your code (in a production
     * environment if possible) before spending a lot of effort on tweaking a particular element.
     *
     * <h3>Other types of preconditions</h3>
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 08 18:10:02 GMT 2026
    - 53.5K bytes
    - Click Count (0)
Back to Top