- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 247 for runnable (0.04 sec)
-
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(
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 2.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
*/ @J2ktIncompatible @GwtIncompatible // concurrency static Thread newThread(String name, Runnable runnable) { checkNotNull(name); checkNotNull(runnable); // TODO(b/139726489): Confirm that null is impossible here. Thread result = requireNonNull(platformThreadFactory().newThread(runnable)); try { result.setName(name); } catch (SecurityException e) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Oct 08 18:55:33 UTC 2025 - 45.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
val taskRunner: TaskRunner = TaskRunner( object : TaskRunner.Backend { override fun execute( taskRunner: TaskRunner, runnable: Runnable, ) { taskRunner.assertLockHeld() val queuedTask = RunnableSerialTask(runnable) serialTaskQueue += queuedTask executeCallCount++ isParallel = serialTaskQueue.size > 1 }Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
} @Override public void shutdown() { delegate().shutdown(); } @Override @CanIgnoreReturnValue public List<Runnable> shutdownNow() { return delegate().shutdownNow(); } @Override public void execute(Runnable command) { delegate().execute(command); } @Override public <T extends @Nullable Object> Future<T> submit(Callable<T> task) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
return true; } @Override public void execute(Runnable runnable) {} @Override public <V> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return NeverScheduledFuture.create();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 6.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java
*/ @Override ListenableScheduledFuture<?> scheduleAtFixedRate( Runnable command, long initialDelay, long period, TimeUnit unit); /** * @since 15.0 (previously returned ScheduledFuture) */ @Override ListenableScheduledFuture<?> scheduleWithFixedDelay( Runnable command, long initialDelay, long delay, TimeUnit unit);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Feb 11 17:30:04 UTC 2025 - 2.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
inBetween.assertRun(); after.assertRun(); } public void testMisbehavingListenerAlreadyDone() { class BadRunnableException extends RuntimeException {} Runnable bad = new Runnable() { @Override public void run() { throw new BadRunnableException(); } }; future.set(1);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 15.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/reflect/AbstractInvocationHandlerTest.java
.addEqualityGroup(newDelegatingList(LIST2)) .addEqualityGroup( newProxyWithEqualsForInterfaces(List.class, Runnable.class), newProxyWithEqualsForInterfaces(List.class, Runnable.class)) .addEqualityGroup(newProxyWithEqualsForInterfaces(Runnable.class, List.class)) .addEqualityGroup( newDelegatingListWithEquals(LIST1), newDelegatingListWithEquals(LIST1),
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 28 02:48:50 UTC 2024 - 5.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java
} @Override public final ScheduledFuture<?> scheduleAtFixedRate( Runnable command, long initialDelay, long period, TimeUnit unit) { return delegate.scheduleAtFixedRate(wrapTask(command), initialDelay, period, unit); } @Override public final ScheduledFuture<?> scheduleWithFixedDelay( Runnable command, long initialDelay, long delay, TimeUnit unit) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
public Integer call() { return counter.incrementAndGet(); } }); CyclicBarrier barrier = new CyclicBarrier(numThreads + 1); Runnable wrapper = new Runnable() { @Override public void run() { awaitUnchecked(barrier); task.run(); awaitUnchecked(barrier); } };
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 7.2K bytes - Viewed (0)