- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 512 for Runnable (7.91 sec)
-
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
throws InterruptedException, ExecutionException, TimeoutException { checkNotNull(unit); return get(); } @Override public void addListener(Runnable runnable, Executor executor) { Listener listener = new Listener(runnable, executor); if (isDone()) { listener.execute(); } else { listeners.add(listener); } } @CanIgnoreReturnValue
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jan 22 19:37:41 GMT 2024 - 12.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java
* to any {@code Runnable} passed to the default implementation of {@link #wrapTask(Runnable)}. */ protected abstract <T extends @Nullable Object> Callable<T> wrapTask(Callable<T> callable); /** * Wraps a {@code Runnable} for submission to the underlying executor. The default implementation * delegates to {@link #wrapTask(Callable)}. */ protected Runnable wrapTask(Runnable command) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 5.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java
*/ @CanIgnoreReturnValue // TODO(kak): consider removing this @Override protected final <T extends @Nullable Object> RunnableFuture<T> newTaskFor( Runnable runnable, @ParametricNullness T value) { return TrustedListenableFutureTask.create(runnable, value); } /** * @since 19.0 (present with return type {@code ListenableFutureTask} since 14.0) */ @CanIgnoreReturnValue // TODO(kak): consider removing this
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
} @Override @SuppressWarnings("CatchingUnchecked") // sneaky checked exception public void runWithTimeout(Runnable runnable, long timeoutDuration, TimeUnit timeoutUnit) { checkNotNull(runnable); checkNotNull(timeoutUnit); try { runnable.run(); } catch (Exception e) { // sneaky checked exception throw new UncheckedExecutionException(e); } catch (Error e) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 3.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/AbstractTester.java
*/ @GwtCompatible(emulated = true) @ElementTypesAreNonnullByDefault public class AbstractTester<G> extends TestCase { private G subjectGenerator; private String suiteName; private @Nullable Runnable setUp; private @Nullable Runnable tearDown; // public so that it can be referenced in generated GWT tests. @Override public void setUp() throws Exception { if (setUp != null) { setUp.run(); } }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 16:49:06 GMT 2024 - 2.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/reflect/ReflectionTest.java
assertEquals("java.util", Reflection.getPackageName(Map.Entry.class)); } public void testNewProxy() throws Exception { Runnable runnable = Reflection.newProxy(Runnable.class, X_RETURNER); assertEquals("x", runnable.toString()); } public void testNewProxyCantWorkOnAClass() throws Exception { assertThrows(
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 2.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/reflect/ReflectionTest.java
assertEquals("java.util", Reflection.getPackageName(Map.Entry.class)); } public void testNewProxy() throws Exception { Runnable runnable = Reflection.newProxy(Runnable.class, X_RETURNER); assertEquals("x", runnable.toString()); } public void testNewProxyCantWorkOnAClass() throws Exception { assertThrows(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 2.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Callables.java
boolean unused = trySetName(oldName, currentThread); } } }; } /** * Wraps the given runnable such that for the duration of {@link Runnable#run} the thread that is * running with have the given name. * * @param task The Runnable to wrap * @param nameSupplier The supplier of thread names, {@link Supplier#get get} will be called once
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 4.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
*/ protected ScheduledExecutorService executor() { @WeakOuter class ThreadFactoryImpl implements ThreadFactory { @Override public Thread newThread(Runnable runnable) { return MoreExecutors.newThread(serviceName(), runnable); } } final ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl());
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) -
guava-tests/test/com/google/common/eventbus/AsyncEventBusTest.java
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.3K bytes - Viewed (0)