Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 40 for Workers (0.18 sec)

  1. guava/src/com/google/common/collect/EvictingQueue.java

    import java.util.Collection;
    import java.util.Queue;
    
    /**
     * A non-blocking queue which automatically evicts elements from the head of the queue when
     * attempting to add new elements onto the queue and it is full. This queue orders elements FIFO
     * (first-in-first-out). This data structure is logically equivalent to a circular buffer (i.e.,
     * cyclic buffer or ring buffer).
     *
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Fri May 12 17:52:55 GMT 2023
    - 4.6K bytes
    - Viewed (0)
  2. 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)
  3. android/guava-tests/test/com/google/common/collect/LinkedHashMultimapTest.java

        assertThat(multimap.entries())
            .containsExactly(mapEntry("b", 2), mapEntry("a", 3), mapEntry("c", 4))
            .inOrder();
        // note that the keys and entries are in different orders
      }
    
      private void assertOrderingReadOnly(Multimap<String, Integer> multimap) {
        assertThat(multimap.get("foo")).containsExactly(5, 3).inOrder();
        assertThat(multimap.get("bar")).containsExactly(4, 1).inOrder();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 21 10:16:44 GMT 2024
    - 16.3K bytes
    - Viewed (0)
  4. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.TimeUnit;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * A bounded {@linkplain BlockingQueue blocking queue} backed by an array. This queue orders
     * elements FIFO (first-in-first-out). The head of the queue is that element that has been
     * on the queue the longest time. The tail of the queue is that element that has been on
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Apr 19 19:24:36 GMT 2023
    - 22.5K bytes
    - Viewed (0)
  5. maven-core/src/main/java/org/apache/maven/execution/MavenExecutionResult.java

        DependencyResolutionResult getDependencyResolutionResult();
    
        // for each exception
        // - knowing what artifacts are missing
        // - project building exception
        // - invalid project model exception: list of markers
        // - xmlpull parser exception
        List<Throwable> getExceptions();
    
        MavenExecutionResult addException(Throwable e);
    
        boolean hasExceptions();
    
        /**
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Wed Sep 06 08:39:32 GMT 2023
    - 2.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/ByFunctionOrdering.java

    import com.google.common.base.Objects;
    import java.io.Serializable;
    import javax.annotation.CheckForNull;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * An ordering that orders elements by applying an order to the result of a function on those
     * elements.
     */
    @GwtCompatible(serializable = true)
    @ElementTypesAreNonnullByDefault
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Sun Jun 20 14:22:42 GMT 2021
    - 2.3K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/TreeBasedTable.java

      }
    
      /**
       * Creates an empty {@code TreeBasedTable} that is ordered by the specified comparators.
       *
       * @param rowComparator the comparator that orders the row keys
       * @param columnComparator the comparator that orders the column keys
       */
      public static <R, C, V> TreeBasedTable<R, C, V> create(
          Comparator<? super R> rowComparator, Comparator<? super C> columnComparator) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 21:19:52 GMT 2024
    - 11.4K bytes
    - Viewed (0)
  8. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

       * orders its elements according to their {@linkplain Comparable natural ordering}.
       */
      public MonitorBasedPriorityBlockingQueue() {
        q = new PriorityQueue<E>();
      }
    
      /**
       * Creates a {@code MonitorBasedPriorityBlockingQueue} with the specified initial capacity that
       * orders its elements according to their {@linkplain Comparable natural ordering}.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 19 19:24:36 GMT 2023
    - 19.5K bytes
    - Viewed (0)
  9. 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)
  10. android/guava-testlib/src/com/google/common/collect/testing/Helpers.java

       * </ul>
       */
      public static <T extends @Nullable Object> void testComparator(
          Comparator<? super T> comparator, List<T> valuesInExpectedOrder) {
        // This does an O(n^2) test of all pairs of values in both orders
        for (int i = 0; i < valuesInExpectedOrder.size(); i++) {
          T t = valuesInExpectedOrder.get(i);
    
          for (int j = 0; j < i; j++) {
            T lesser = valuesInExpectedOrder.get(j);
            assertTrue(
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Feb 26 19:46:10 GMT 2024
    - 17.7K bytes
    - Viewed (0)
Back to top