Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 501 for runnable (0.06 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. android/guava/src/com/google/common/util/concurrent/ForwardingListeningExecutorService.java

        return delegate().submit(task);
      }
    
      @Override
      public ListenableFuture<?> submit(Runnable task) {
        return delegate().submit(task);
      }
    
      @Override
      public <T extends @Nullable Object> ListenableFuture<T> submit(
          Runnable task, @ParametricNullness T result) {
        return delegate().submit(task, result);
      }
    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)
  6. 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)
  7. 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)
  8. build-logic/buildquality/src/main/kotlin/gradlebuild.arch-test.gradle.kts

                }
            }
        }
    }
    
    tasks.codeQuality.configure {
        dependsOn(testing.suites.named("archTest"))
    }
    
    fun notForAccessorGeneration(runnable: Runnable) {
        if (project.name != "gradle-kotlin-dsl-accessors" && project.name != "test") {
            runnable.run()
        }
    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)
  9. 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)
  10. 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)
Back to Top