- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 407 for take (0.66 sec)
-
android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java
@Override public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { return delegate().offer(e, timeout, unit); } @Override public E take() throws InterruptedException { return delegate().take(); } @Override @CheckForNull public E poll(long timeout, TimeUnit unit) throws InterruptedException { return delegate().poll(timeout, unit); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Mar 13 14:30:51 GMT 2023 - 4.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
// we allow one second worth of work to go in a burst (i.e. take less than a second) assertTrue(burst <= 1000); long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random()); // but work beyond that must take at least one second assertTrue(afterBurst >= 1000); } } /**
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.6K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheBuilderSpec.java
this.strength = strength; } @Override public void parse(CacheBuilderSpec spec, String key, @CheckForNull String value) { checkArgument(value == null, "key %s does not take values", key); checkArgument(spec.keyStrength == null, "%s was already set to %s", key, spec.keyStrength); spec.keyStrength = strength; } } /** Parse weakValues and softValues */
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Aug 22 14:27:44 GMT 2022 - 18.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/escape/EscapersTest.java
assertEquals("XheXXuickXXrownXXoxX", builder.build().escape("The Quick Brown Fox!")); // Explicit replacements take priority over unsafe characters. builder.addEscape(' ', "_"); builder.addEscape('!', "_"); assertEquals("Xhe_Xuick_Xrown_Xox_", builder.build().escape("The Quick Brown Fox!")); // Explicit replacements take priority over safe characters. builder.setSafeRange(' ', '~');
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/NullnessCasts.java
* * <p>This method is intended to help with usages of type parameters that have {@linkplain * ParametricNullness parametric nullness}. Sometimes, code may receive a null {@code T} but store * a "null sentinel" to take its place. When the time comes to convert it back to a {@code T} to * return to a caller, the code needs to a way to return {@code null} from a method that returns * "plain {@code T}." This API provides that. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 10 20:36:34 GMT 2022 - 3.9K bytes - Viewed (0) -
guava/src/com/google/common/collect/JdkBackedImmutableMap.java
* detected. This implementation may replace the entries in entryArray with its own entry objects * (though they will have the same key/value contents), and will take ownership of entryArray. */ static <K, V> ImmutableMap<K, V> create( int n, @Nullable Entry<K, V>[] entryArray, boolean throwIfDuplicateKeys) { Map<K, V> delegateMap = Maps.newHashMapWithExpectedSize(n);
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Nov 30 21:54:06 GMT 2023 - 4.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
} } /** Manages a {@link BlockingQueue} and associated timings for a {@code take} call. */ private static final class TimedTakeQueue { final BlockingQueue<String> queue; final Completion completed; /** * Creates a {@link EnableReads} which insert an element for a {@code take} to receive in {@code * countdownInMillis}. */
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 31.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java
@Override public int remainingCapacity() { return delegate().remainingCapacity(); } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public E take() throws InterruptedException { return delegate().take(); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 3K bytes - Viewed (0) -
guava/src/com/google/common/collect/ForwardingBlockingDeque.java
@Override public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { return delegate().offer(e, timeout, unit); } @Override public E take() throws InterruptedException { return delegate().take(); } @Override @CheckForNull public E poll(long timeout, TimeUnit unit) throws InterruptedException { return delegate().poll(timeout, unit); }
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Mar 13 14:30:51 GMT 2023 - 4.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* maxPermits is equal to warmupPeriod. * <li>When _used_, the time it takes, as explained in the introductory class note, is equal to * the integral of our function, between X permits and X-K permits, assuming we want to * spend K saved permits. * </ol> *
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)