Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 120 for Schedule (0.04 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

          private ScheduledFuture<@Nullable Void> submitToExecutor(Schedule schedule) {
            return executor.schedule(this, schedule.delay, schedule.unit);
          }
        }
    
        /**
         * Contains the most recently submitted {@code Future}, which may be cancelled or updated,
         * always under a lock.
         */
        private static final class SupplantableFuture implements Cancellable {
          private final ReentrantLock lock;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

          private ScheduledFuture<@Nullable Void> submitToExecutor(Schedule schedule) {
            return executor.schedule(this, schedule.delay, schedule.unit);
          }
        }
    
        /**
         * Contains the most recently submitted {@code Future}, which may be cancelled or updated,
         * always under a lock.
         */
        private static final class SupplantableFuture implements Cancellable {
          private final ReentrantLock lock;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt

          object : Task("task one") {
            val schedules = mutableListOf(200.µs)
    
            override fun runOnce(): Long {
              if (schedules.isNotEmpty()) {
                redQueue.schedule(this, schedules.removeAt(0)) // Add it at the end also.
              }
              log += "scheduledTasks=${redQueue.scheduledTasks}"
              return -1L
            }
          }
        redQueue.schedule(task, 100.µs)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 23K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

       */
      fun schedule(
        task: Task,
        delayNanos: Long = 0L,
      ) {
        taskRunner.withLock {
          if (shutdown) {
            if (task.cancelable) {
              taskRunner.logger.taskLog(task, this) { "schedule canceled (queue is shutdown)" }
              return
            }
            taskRunner.logger.taskLog(task, this) { "schedule failed (queue is shutdown)" }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  5. 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)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

        return new NoOpScheduledExecutorService();
      }
    
      /**
       * Creates a scheduled executor service that runs each task in the thread that invokes {@code
       * execute/submit/schedule}, as in {@link CallerRunsPolicy}. This applies both to individually
       * submitted tasks and to collections of tasks submitted via {@code invokeAll}, {@code invokeAny},
       * {@code schedule}, {@code scheduleAtFixedRate}, and {@code scheduleWithFixedDelay}. In the case
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java

      }
    
      @Override
      public final ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(command), delay, unit);
      }
    
      @Override
      public final <V extends @Nullable Object> ScheduledFuture<V> schedule(
          Callable<V> task, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(task), delay, unit);
      }
    
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        MockExecutor mock = new MockExecutor();
        TestExecutor testExecutor = new TestExecutor(mock);
    
        Future<?> unused1 = testExecutor.schedule(DO_NOTHING, 10, MINUTES);
        mock.assertLastMethodCalled("scheduleRunnable", 10, MINUTES);
    
        Future<?> unused2 = testExecutor.schedule(callable(DO_NOTHING), 5, SECONDS);
        mock.assertLastMethodCalled("scheduleCallable", 5, SECONDS);
      }
    
      public void testSchedule_repeating() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

        return new NoOpScheduledExecutorService();
      }
    
      /**
       * Creates a scheduled executor service that runs each task in the thread that invokes {@code
       * execute/submit/schedule}, as in {@link CallerRunsPolicy}. This applies both to individually
       * submitted tasks and to collections of tasks submitted via {@code invokeAll}, {@code invokeAny},
       * {@code schedule}, {@code scheduleAtFixedRate}, and {@code scheduleWithFixedDelay}. In the case
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java

      }
    
      @Override
      public final ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(command), delay, unit);
      }
    
      @Override
      public final <V extends @Nullable Object> ScheduledFuture<V> schedule(
          Callable<V> task, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(task), delay, unit);
      }
    
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
Back to top