- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 501 for runnable (0.07 seconds)
-
android/guava-testlib/test/com/google/common/collect/testing/FeatureSpecificTestSuiteBuilderTest.java
return Collections.<Class<? extends AbstractTester>>singletonList(MyTester.class); } } public void testLifecycle() { boolean[] setUp = {false}; Runnable setUpRunnable = () -> setUp[0] = true; boolean[] tearDown = {false}; Runnable tearDownRunnable = () -> tearDown[0] = true; MyTestSuiteBuilder builder = new MyTestSuiteBuilder(); Test test = builder .usingGenerator("yam")
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 2.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/CacheLoaderTest.java
* @author Charles Fry */ @NullUnmarked public class CacheLoaderTest extends TestCase { private static class QueuingExecutor implements Executor { private final Deque<Runnable> tasks = new ArrayDeque<>(); @Override public void execute(Runnable task) { tasks.add(task); } private void runNext() { tasks.removeFirst().run(); } } public void testAsyncReload() throws Exception {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 30 22:03:28 GMT 2025 - 3.8K bytes - Click Count (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
import java.util.concurrent.ExecutionException; import junit.framework.Assert; /** * A simple mock implementation of {@code Runnable} that can be used for testing ListenableFutures. * * @author Nishant Thakkar * @since 10.0 */ @GwtIncompatible public class MockFutureListener implements Runnable { private final CountDownLatch countDownLatch; private final ListenableFuture<?> future;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri May 12 18:12:42 GMT 2023 - 3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/RecordingExecutor.kt
private val dispatcherTest: DispatcherTest, ) : AbstractExecutorService() { private var shutdown: Boolean = false private val calls = mutableListOf<RealCall.AsyncCall>() override fun execute(command: Runnable) { if (shutdown) throw RejectedExecutionException() calls.add(command as RealCall.AsyncCall) } fun assertJobs(vararg expectedUrls: String) { val actualUrls = calls.map { it.request.url.toString() }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Oct 06 18:34:01 GMT 2025 - 2.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingListeningExecutorService.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
} } /** * Submits the given runnable to the given {@link Executor} catching and logging all {@linkplain * RuntimeException runtime exceptions} thrown by the executor. */ @SuppressWarnings("CatchingUnchecked") // sneaky checked exception private static void executeListener(Runnable runnable, Executor executor) { try { executor.execute(runnable);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 43.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/util/ComponentUtilTest.java
List<String> results = new ArrayList<>(); Runnable process = () -> results.add("executed"); ComponentUtil.processAfterContainerInit(process); assertEquals(0, results.size()); } @Test public void test_processAfterContainerInit_notAvailable() { List<String> results = new ArrayList<>(); Runnable process = () -> results.add("executed");
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 7.7K bytes - Click Count (0) -
build-logic/buildquality/src/main/kotlin/gradlebuild.arch-test.gradle.kts
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Feb 10 08:11:56 GMT 2026 - 3.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
@Override public String get(long time, TimeUnit unit) { return "foo"; // BAD!! } @Override public void addListener(Runnable runnable, Executor executor) { executor.execute(runnable); } }; Future<?> future = newFutureInstance(); future .getClass() .getMethod( "setFuture",Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 6.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
@Override public String get(long time, TimeUnit unit) { return "foo"; // BAD!! } @Override public void addListener(Runnable runnable, Executor executor) { executor.execute(runnable); } }; Future<?> future = newFutureInstance(); future .getClass() .getMethod( "setFuture",Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 6.3K bytes - Click Count (0)