Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for Worker (0.2 sec)

  1. 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")
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java

      /**
       * Returns the {@link Executor} that will be used to run this service. Subclasses may override
       * this method to use a custom {@link Executor}, which may configure its worker thread with a
       * specific name, thread group or priority. The returned executor's {@link
       * Executor#execute(Runnable) execute()} method is called when this service is started and
       * stopped, and should return promptly.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 17 13:59:28 GMT 2023
    - 5.3K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/net/HttpHeaders.java

        public static final String UNSAFE_URL = "unsafe-url";
      }
    
      /**
       * The HTTP <a href="https://www.w3.org/TR/service-workers/#update-algorithm">{@code
       * Service-Worker}</a> header field name.
       *
       * @since 20.0
       */
      public static final String SERVICE_WORKER = "Service-Worker";
      /** The HTTP {@code TE} header field name. */
      public static final String TE = "TE";
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:08:08 GMT 2024
    - 34.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      /**
       * Returns the {@link Executor} that will be used to run this service. Subclasses may override
       * this method to use a custom {@link Executor}, which may configure its worker thread with a
       * specific name, thread group or priority. The returned executor's {@link
       * Executor#execute(Runnable) execute()} method is called when this service is started, and should
       * return promptly.
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 7.6K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/QueuesTest.java

      @Override
      public void setUp() {
        threadPool = newCachedThreadPool();
      }
    
      @Override
      public void tearDown() throws InterruptedException {
        threadPool.shutdown();
        assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS));
      }
    
      private static <T> int drain(
          BlockingQueue<T> q,
          Collection<? super T> buffer,
          int maxElements,
          long timeout,
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/QueuesTest.java

      @Override
      public void setUp() {
        threadPool = newCachedThreadPool();
      }
    
      @Override
      public void tearDown() throws InterruptedException {
        threadPool.shutdown();
        assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS));
      }
    
      private static <T> int drain(
          BlockingQueue<T> q,
          Collection<? super T> buffer,
          int maxElements,
          long timeout,
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12K bytes
    - Viewed (0)
  7. guava-tests/benchmark/com/google/common/collect/MapBenchmark.java

    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentSkipListMap;
    
    /**
     * A microbenchmark that tests the performance of get() and iteration on various map
     * implementations. Forked from {@link SetContainsBenchmark}.
     *
     * @author Nicholaus Shupe
     */
    public class MapBenchmark {
      @Param({"Hash", "LinkedHM", "MapMaker1", "Immutable"})
      private Impl impl;
    
      public enum Impl {
        Hash {
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 7.6K bytes
    - Viewed (0)
  8. guava-testlib/src/com/google/common/collect/testing/google/SortedMultisetTestSuiteBuilder.java

                    return ((SortedMultiset<E>) super.create(entries)).descendingMultiset();
                  }
    
                  @Override
                  public Iterable<E> order(List<E> insertionOrder) {
                    return ImmutableList.copyOf(super.order(insertionOrder)).reverse();
                  }
                })
            .named(parentBuilder.getName() + " descending")
            .withFeatures(features)
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Feb 26 19:46:10 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/google/SortedMultisetTestSuiteBuilder.java

                    return ((SortedMultiset<E>) super.create(entries)).descendingMultiset();
                  }
    
                  @Override
                  public Iterable<E> order(List<E> insertionOrder) {
                    return ImmutableList.copyOf(super.order(insertionOrder)).reverse();
                  }
                })
            .named(parentBuilder.getName() + " descending")
            .withFeatures(features)
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Feb 26 19:46:10 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       *
       * <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.
       *
       * <p>The executor uses {@code delegate} in order to {@link Executor#execute execute} each task in
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
Back to top