Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for chooser (0.04 sec)

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

                    new ClosingCallable<TestCloseable>() {
                      @Override
                      public TestCloseable call(DeferredCloser closer) throws Exception {
                        closer.eventuallyClose(closeable1, closingExecutor);
                        closer.eventuallyClose(closeable2, closingExecutor);
                        return closeable3;
                      }
                    },
                    executor)
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 75.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/Sets.java

       * iterated are the individual lists created, and these are not retained after iteration.
       *
       * @param sets the sets to choose elements from, in the order that the elements chosen from those
       *     sets should appear in the resulting lists
       * @param <B> any common base class shared by all axes (often just {@link Object})
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 81.6K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    	total := serverPools.TotalAvailable()
    	if total == 0 {
    		return -1
    	}
    	// choose when we reach this many
    	choose := rand.Uint64() % total
    	atTotal := uint64(0)
    	for _, pool := range serverPools {
    		atTotal += pool.Available
    		if atTotal > choose && pool.Available > 0 {
    			return pool.Index
    		}
    	}
    	// Should not happen, but print values just in case.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/cache/CacheBuilder.java

       * without contention. Because assignment of entries to these partitions is not necessarily
       * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to
       * accommodate as many threads as will ever concurrently modify the table. Using a significantly
       * higher value than you need can waste space and time, and a significantly lower value can lead
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

       */
      // TODO(fry): empirically optimize this
      static final int DRAIN_MAX = 16;
    
      // Fields
    
      /**
       * Mask value for indexing into segments. The upper bits of a key's hash code are used to choose
       * the segment.
       */
      final transient int segmentMask;
    
      /**
       * Shift value for indexing within segments. Helps prevent entries that end up in the same segment
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/Futures.java

       * ListenableFuture<Integer> faultTolerantFuture = Futures.catchingAsync(
       *     fetchCounterFuture, FetchException.class, x -> immediateFuture(0), directExecutor());
       * }
       *
       * <p>The fallback can also choose to propagate the original exception when desired:
       *
       * {@snippet :
       * ListenableFuture<Integer> fetchCounterFuture = ...;
       *
       * // Falling back to a zero counter only in case the exception was a
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  7. src/main/webapp/js/admin/plugins/daterangepicker/daterangepicker.js

                // * if the time picker is enabled, apply the hour/minute/second from the select boxes to the clicked date
                // * if autoapply is enabled, and an end date was chosen, apply the selection
                // * if single date picker mode, and time picker isn't enabled, apply the selection immediately
                // * if one of the inputs above the calendars was focused, cancel that manual input
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 64.8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/Iterators.java

       * returned to the caller, although this is neither guaranteed to occur nor required to be
       * consistent. For example, this method <i>might</i> choose to pass through recognized
       * implementations of {@code PeekingIterator} when the behavior of the implementation is known to
       * meet the contract guaranteed by this method.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 50.5K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    		case isSysErrTooManyFiles(err):
    			return nil, errTooManyOpenFiles
    		default:
    			return nil, err
    		}
    	}
    
    	return w, nil
    }
    
    type sendFileReader struct {
    	io.Reader
    	io.Closer
    }
    
    // ReadFileStream - Returns the read stream of the file.
    func (s *xlStorage) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	if offset < 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    
        // Note that although we have two routes available, we only use one. The retry is permitted
        // because there are routes available, but it chooses the existing connection since it isn't
        // yet considered unhealthy.
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(1)
      }
    
      @ParameterizedTest
      @ArgumentsSource(ProtocolParamProvider::class)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
Back to top