Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 226 for runnable (0.35 sec)

  1. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      }
    
      @Override
      public <T> ListenableFuture<T> submit(Runnable task, T result) {
        Preconditions.checkNotNull(task, "task must not be null!");
        Preconditions.checkNotNull(result, "result must not be null!");
        return delegate.submit(task, result);
      }
    
      @Override
      public ListenableFuture<?> submit(Runnable task) {
        Preconditions.checkNotNull(task, "task must not be null!");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      }
    
      @Override
      public <T> ListenableFuture<T> submit(Runnable task, T result) {
        Preconditions.checkNotNull(task, "task must not be null!");
        Preconditions.checkNotNull(result, "result must not be null!");
        return delegate.submit(task, result);
      }
    
      @Override
      public ListenableFuture<?> submit(Runnable task) {
        Preconditions.checkNotNull(task, "task must not be null!");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

          Runnable runnable, @ParametricNullness V result) {
        return new ListenableFutureTask<>(runnable, result);
      }
    
      ListenableFutureTask(Callable<V> callable) {
        super(callable);
      }
    
      ListenableFutureTask(Runnable runnable, @ParametricNullness V result) {
        super(runnable, result);
      }
    
      @Override
      public void addListener(Runnable listener, Executor exec) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java

       */
      @Override
      ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit);
    
      /**
       * Duration-based overload of {@link #schedule(Runnable, long, TimeUnit)}.
       *
       * @since 29.0
       */
      @J2ktIncompatible
      default ListenableScheduledFuture<?> schedule(Runnable command, Duration delay) {
        return schedule(command, toNanosSaturated(delay), TimeUnit.NANOSECONDS);
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Feb 11 17:30:04 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  5. guava-testlib/test/com/google/common/collect/testing/FeatureSpecificTestSuiteBuilderTest.java

        }
      }
    
      public void testLifecycle() {
        boolean[] setUp = {false};
        Runnable setUpRunnable =
            new Runnable() {
              @Override
              public void run() {
                setUp[0] = true;
              }
            };
    
        boolean[] tearDown = {false};
        Runnable tearDownRunnable =
            new Runnable() {
              @Override
              public void run() {
                tearDown[0] = true;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Jan 25 16:19:30 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/collect/testing/google/ReflectionFreeAssertThrows.java

      }
    
      @CanIgnoreReturnValue
      static <T extends Throwable> T assertThrows(
          Class<T> expectedThrowable, ThrowingRunnable runnable) {
        return doAssertThrows(
            expectedThrowable,
            () -> {
              runnable.run();
              return null;
            },
            /* userPassedSupplier= */ false);
      }
    
      private static <T extends Throwable> T doAssertThrows(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/sereq/AdminSereqAction.java

         *
         * @param runnable optional runnable to execute before rendering (can be null)
         * @return HTML response for the search request list page
         */
        private HtmlResponse asListHtml(final Runnable runnable) {
            if (runnable != null) {
                runnable.run();
            }
            return asHtml(path_AdminSereq_AdminSereqJsp).useForm(UploadForm.class);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

       * otherwise-concurrent GC cycle.
       */
      private static final class TaskNonReentrantExecutor extends AtomicReference<RunningState>
          implements Executor, Runnable {
    
        /**
         * Used to update and read the latestTaskQueue field. Set to null once the runnable has been run
         * or queued.
         */
        @Nullable ExecutionSequencer sequencer;
    
        /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  9. 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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  10. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Feb 11 17:30:04 UTC 2025
    - 2.1K bytes
    - Viewed (0)
Back to top