- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 110 for donec (0.2 sec)
-
android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* instead), and postpone /subsequent/ requests as needed. In this version, we allow starting the * task immediately, and postpone by 100 seconds future requests, thus we allow for work to get * done in the meantime instead of waiting idly. * * This has important consequences: it means that the RateLimiter doesn't remember the time of the
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) -
android/guava/src/com/google/common/base/Converter.java
return doBackward(uncheckedCastNullableTToT(b)); } /** * Returns an iterable that applies {@code convert} to each element of {@code fromIterable}. The * conversion is done lazily. * * <p>The returned iterable's iterator supports {@code remove()} if the input iterator does. After * a successful {@code remove()} call, {@code fromIterable} no longer contains the corresponding * element.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 23K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
doneSignal.countDown(); } }); thread.start(); boolean done = doneSignal.await(1, TimeUnit.SECONDS); if (!done) { StringBuilder builder = new StringBuilder(); for (StackTraceElement trace : thread.getStackTrace()) { builder.append("\tat ").append(trace).append('\n'); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 112.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
doneSignal.countDown(); } }); thread.start(); boolean done = doneSignal.await(1, TimeUnit.SECONDS); if (!done) { StringBuilder builder = new StringBuilder(); for (StackTraceElement trace : thread.getStackTrace()) { builder.append("\tat ").append(trace).append('\n'); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 110.7K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java
@BeforeExperiment void setUp() throws Exception { if (state != State.NOT_DONE && (numListeners != 0 || numThreads != 0)) { throw new SkipThisScenarioException(); } } // This exclusion doesn't exclude the TOMBSTONE objects we set. So 'done' NEW futures will look // larger than they are. @SuppressWarnings("FutureReturnValueIgnored")
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Jan 17 15:34:54 GMT 2018 - 3K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java
@BeforeExperiment void setUp() throws Exception { if (state != State.NOT_DONE && (numListeners != 0 || numThreads != 0)) { throw new SkipThisScenarioException(); } } // This exclusion doesn't exclude the TOMBSTONE objects we set. So 'done' NEW futures will look // larger than they are. @SuppressWarnings("FutureReturnValueIgnored")
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Jan 17 15:34:54 GMT 2018 - 3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
/* * If the output future is done, then it won't need to interrupt the task later, so it can clear * its reference to it. * * If the output future is *not* done, then the task field will be cleared after the task runs * or after the output future is done, whichever comes first. */ if (reason == OUTPUT_FUTURE_DONE) { this.task = null; } } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 6.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* done. */ public static final class DeferredCloser { @RetainedWith private final CloseableList list; DeferredCloser(CloseableList list) { this.list = list; } /** * Captures an object to be closed when a {@link ClosingFuture} pipeline is done. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
/** * A {@link FutureTask} that also implements the {@link ListenableFuture} interface. Unlike {@code * FutureTask}, {@code ListenableFutureTask} does not provide an overrideable {@link * FutureTask#done() done()} method. For similar functionality, call {@link #addListener}. * * <p>Few users should use this class. It is intended primarily for those who are implementing an
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestPlatform.java
Thread.interrupted(); } /** * Retrieves the result of a {@code Future} known to be done but uses the {@code get(long, * TimeUnit)} overload in order to test that method. */ static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { checkState(future.isDone(), "Future was expected to be done: %s", future); try { return getUninterruptibly(future, 0, SECONDS);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.9K bytes - Viewed (0)