- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 76 for Kistner (0.4 sec)
-
android/guava/src/com/google/common/cache/RemovalListener.java
* shared resources. * * @param <K> the most general type of keys this listener can listen for; for example {@code Object} * if any key is acceptable * @param <V> the most general type of values this listener can listen for; for example {@code * Object} if any key is acceptable * @author Charles Fry * @since 10.0 */ @GwtCompatible
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Jun 15 18:00:07 GMT 2021 - 2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
super(callable); } ListenableFutureTask(Runnable runnable, @ParametricNullness V result) { super(runnable, result); } @Override public void addListener(Runnable listener, Executor exec) { executionList.add(listener, exec); } @CanIgnoreReturnValue @Override @ParametricNullness public V get(long timeout, TimeUnit unit) throws TimeoutException, InterruptedException, ExecutionException {
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/src/com/google/common/util/concurrent/AbstractScheduledService.java
} @Override public final State state() { return delegate.state(); } /** @since 13.0 */ @Override public final void addListener(Listener listener, Executor executor) { delegate.addListener(listener, executor); } /** @since 14.0 */ @Override public final Throwable failureCause() { return delegate.failureCause(); } /** @since 15.0 */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown(); assertEquals(25, task.get().intValue()); assertTrue(listenerLatch.await(5, TimeUnit.SECONDS)); assertTrue(task.isDone());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.7K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheBuilder.java
return ticker; } return recordsTime ? Ticker.systemTicker() : NULL_TICKER; } /** * Specifies a listener instance that caches should notify each time an entry is removed for any * {@linkplain RemovalCause reason}. Each cache created by this builder will invoke this listener * as part of the routine maintenance described in the class documentation above. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 44.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
} finally { joinPool(e); } } private static void assertListenerRunImmediately(ListenableFuture<?> future) { CountingRunnable listener = new CountingRunnable(); future.addListener(listener, directExecutor()); assertEquals(1, listener.count); } private static final class CountingRunnable implements Runnable { int count; @Override public void run() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (3) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
return sync.wasInterrupted(); } /** * {@inheritDoc} * * @since 10.0 */ @Override public void addListener(Runnable listener, Executor exec) { executionList.add(listener, exec); } /** * Subclasses should invoke this method to set the result of the computation to {@code value}.
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed May 09 15:17:25 GMT 2018 - 13.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
return sync.wasInterrupted(); } /** * {@inheritDoc} * * @since 10.0 */ @Override public void addListener(Runnable listener, Executor exec) { executionList.add(listener, exec); } /** * Subclasses should invoke this method to set the result of the computation to {@code value}.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
new Thread(() -> latch.countDown()).start(); } future.addListener(listenerLatch::countDown, exec); } assertSame(Boolean.TRUE, future.get()); // Wait for the listener latch to complete. listenerLatch.await(500, MILLISECONDS); exec.shutdown(); exec.awaitTermination(500, MILLISECONDS); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
} }; // Adding the listener to both futures guarantees that newFuture will always be set. Adding to // taskFuture guarantees completion if the callable is invoked, and adding to outputFuture // propagates cancellation if the callable has not yet been invoked. outputFuture.addListener(listener, directExecutor()); taskFuture.addListener(listener, directExecutor()); return outputFuture; }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0)