Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 578 for executer (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

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

      }
    
      /**
       * Returns an {@link Executor} that runs each task executed sequentially, such that no two tasks
       * are running concurrently.
       *
       * <p>{@linkplain Executor#execute executed} tasks have a happens-before order as defined in the
       * Java Language Specification. Tasks execute with the same happens-before order that the function
       * calls to {@link Executor#execute execute()} that submitted those tasks had.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 45.2K bytes
    - Click Count (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

          final Executor executor;
    
          RunnableExecutorPair(Runnable runnable, Executor executor) {
            this.runnable = runnable;
            this.executor = executor;
          }
    
          void execute() {
            try {
              executor.execute(runnable);
            } catch (RuntimeException e) {
              log.log(
                  Level.SEVERE,
                  "RuntimeException while executing runnable "
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  3. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * (unless the executor has been shutdown).
       *
       * <p>The returned executor is backed by the executor returned by {@link
       * MoreExecutors#newDirectExecutorService} and subject to the same constraints.
       *
       * <p>Although all tasks are immediately executed in the thread that submitted the task, this
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

                      + runnable
                      + " with executor "
                      + executor,
                  e);
        }
      }
    
      private static final class RunnableExecutorPair {
        final Runnable runnable;
        final Executor executor;
        @Nullable RunnableExecutorPair next;
    
        RunnableExecutorPair(
            Runnable runnable, Executor executor, @Nullable RunnableExecutorPair next) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 6.9K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

      /** Use {@link MoreExecutors#newSequentialExecutor} */
      SequentialExecutor(Executor executor) {
        this.executor = Preconditions.checkNotNull(executor);
      }
    
      /**
       * Adds a task to the queue and makes sure a worker thread is running.
       *
       * <p>If this method throws, e.g. a {@code RejectedExecutionException} from the delegate executor,
       * execution of tasks will stop until a call to this method is made.
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  6. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

      /** Use {@link MoreExecutors#newSequentialExecutor} */
      SequentialExecutor(Executor executor) {
        this.executor = Preconditions.checkNotNull(executor);
      }
    
      /**
       * Adds a task to the queue and makes sure a worker thread is running.
       *
       * <p>If this method throws, e.g. a {@code RejectedExecutionException} from the delegate executor,
       * execution of tasks will stop until a call to this method is made.
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  7. guava/src/com/google/common/cache/RemovalListeners.java

       */
      public static <K, V> RemovalListener<K, V> asynchronous(
          RemovalListener<K, V> listener, Executor executor) {
        checkNotNull(listener);
        checkNotNull(executor);
        return (RemovalNotification<K, V> notification) ->
            executor.execute(() -> listener.onRemoval(notification));
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * {@link #shutDown} and also a {@link #runOneIteration} method that will be executed periodically.
     *
     * <p>This class uses the {@link ScheduledExecutorService} returned from {@link #executor} to run
     * the {@link #startUp} and {@link #shutDown} methods and also uses that service to schedule the
     * {@link #runOneIteration} that will be executed periodically as specified by its {@link
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

                runCalled.getAndIncrement();
              }
            },
            directExecutor());
        Runnable execute =
            new Runnable() {
              @Override
              public void run() {
                list.execute();
              }
            };
        Thread thread1 = new Thread(execute);
        Thread thread2 = new Thread(execute);
        thread1.start();
        thread2.start();
        assertEquals(0, runCalled.get());
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/Service.java

       * @param executor the executor in which the listeners callback methods will be run. For fast,
       *     lightweight listeners that would be safe to execute in any thread, consider {@link
       *     MoreExecutors#directExecutor}.
       * @since 13.0
       */
      void addListener(Listener listener, Executor executor);
    
      /**
       * The lifecycle states of a service.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 10.8K bytes
    - Click Count (0)
Back to Top