- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 40 for Workers (0.18 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)