Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 201 for scheduled (0.08 sec)

  1. android/guava/src/com/google/common/util/concurrent/Futures.java

        Future<?> scheduled = executorService.schedule(task, delay, timeUnit);
        /*
         * Even when the user interrupts the task, we pass `false` to `cancel` so that we don't
         * interrupt a second time after the interruption performed by TrustedListenableFutureTask.
         */
        task.addListener(() -> scheduled.cancel(false), directExecutor());
        return task;
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      }
    
      @Override
      public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        Preconditions.checkNotNull(command, "command must not be null");
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return schedule(Executors.callable(command), delay, unit);
      }
    
      @Override
      public <V> ListenableScheduledFuture<V> schedule(
          Callable<V> callable, long delay, TimeUnit unit) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      }
    
      @Override
      public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        Preconditions.checkNotNull(command, "command must not be null");
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return schedule(Executors.callable(command), delay, unit);
      }
    
      @Override
      public <V> ListenableScheduledFuture<V> schedule(
          Callable<V> callable, long delay, TimeUnit unit) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. pyproject.toml

        # https://github.com/sqlalchemy/sqlalchemy/commit/59521abcc0676e936b31a523bd968fc157fef0c2
        'ignore:datetime\.datetime\.utcfromtimestamp\(\) is deprecated and scheduled for removal in a future version\..*:DeprecationWarning:sqlalchemy',
        # Trio 24.1.0 raises a warning from attrs
        # Ref: https://github.com/python-trio/trio/pull/3054
        # Remove once there's a new version of Trio
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Oct 22 14:19:56 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

       * This counter prevents an ABA issue where a thread may successfully schedule the worker, the
       * worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the
       * worker, and then the first thread's call to delegate.execute() returns. Without this counter,
       * it would observe the QUEUING state and set it to QUEUED, and the worker would never be
       * scheduled again for future submissions.
       */
      @GuardedBy("queue")
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

       * This counter prevents an ABA issue where a thread may successfully schedule the worker, the
       * worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the
       * worker, and then the first thread's call to delegate.execute() returns. Without this counter,
       * it would observe the QUEUING state and set it to QUEUED, and the worker would never be
       * scheduled again for future submissions.
       */
      @GuardedBy("queue")
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/Futures.java

        Future<?> scheduled = executorService.schedule(task, delay, timeUnit);
        /*
         * Even when the user interrupts the task, we pass `false` to `cancel` so that we don't
         * interrupt a second time after the interruption performed by TrustedListenableFutureTask.
         */
        task.addListener(() -> scheduled.cancel(false), directExecutor());
        return task;
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

       * addListener/SES.schedule. The later racy write in cancel() is not guaranteed to be observed,
       * however that is fine since the correctness is based on the atomic state in our base class. The
       * initial write to timer is never definitely visible to Fire.run since it is assigned after
       * SES.schedule is called. Therefore Fire.run has to check for null. However, it should be visible
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/TreeTraverser.java

     *     implements {@code SuccessorsFunction}, which has a similar API as {@link #children} or can be
     *     the same lambda function as passed into {@link #using(Function)}.
     *     <p>This class is scheduled to be removed in October 2019.
     */
    // TODO(b/68134636): Remove by 2019-10
    @Deprecated
    @Beta
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public abstract class TreeTraverser<T> {
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 8.9K bytes
    - Viewed (0)
Back to top