- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 45 for Producers (0.06 seconds)
-
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* automate the process, often adding features like monitoring, debugging, and cancellation. * Examples of frameworks include: * * <ul> * <li><a href="https://dagger.dev/producers.html">Dagger Producers</a> * </ul> * * <p>The main purpose of {@link #addListener addListener} is to support this chaining. You will * rarely use it directly, in part because it does not provide direct access to the {@code Future}
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* automate the process, often adding features like monitoring, debugging, and cancellation. * Examples of frameworks include: * * <ul> * <li><a href="https://dagger.dev/producers.html">Dagger Producers</a> * </ul> * * <p>The main purpose of {@link #addListener addListener} is to support this chaining. You will * rarely use it directly, in part because it does not provide direct access to the {@code Future}
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* use a framework. Frameworks automate the process, often adding features like monitoring, * debugging, and cancellation. Examples of frameworks include: * * <ul> * <li><a href="https://dagger.dev/producers.html">Dagger Producers</a> * </ul> * * <h4>{@link java.util.concurrent.CompletableFuture} / {@link java.util.concurrent.CompletionStage} * </h4> *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 19.8K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* inserted by producers and extracted by consumers. Once created, the capacity cannot be increased. * Attempts to {@code put} an element into a full queue will result in the operation blocking; * attempts to {@code take} an element from an empty queue will similarly block. * * <p>This class supports an optional fairness policy for ordering waiting producer and consumerCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* inserted by producers and extracted by consumers. Once created, the capacity cannot be increased. * Attempts to {@code put} an element into a full queue will result in the operation blocking; * attempts to {@code take} an element from an empty queue will similarly block. * * <p>This class supports an optional fairness policy for ordering waiting producer and consumerCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* monitoring, debugging, and cancellation. Examples of frameworks include: * * <ul> * <li><a href="https://dagger.dev/producers.html">Dagger Producers</a> * </ul> * * <p>If you do chain your operations manually, you may want to use {@link FluentFuture}. * * @author Kevin Bourrillion * @author Nishant Thakkar * @author Sven Mawson
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 64.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, MILLISECONDS)); Producer producer = new Producer(q, 1); // producing one, will ask for two Future<?> producerThread = threadPool.submit(producer); producer.beganProducing.await(); // make sure we time out Stopwatch timer = Stopwatch.createStarted();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 12.6K bytes - Click Count (0) -
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractBinaryCompatibilityTest.kt
* Runs the binary compatibility check against two source trees. * * The fixture build supports both Java and Kotlin sources. * * @param v1 sources producer for V1, receiver is the `src/main` directory * @param v2 sources producer for V2, receiver is the `src/main` directory * @param block convenience block invoked on the result * @return the check result */ privateCreated: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Mon Jan 19 11:30:48 GMT 2026 - 18.3K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/FluentIterable.java
* in this fluent iterable to that value * @throws IllegalArgumentException if {@code keyFunction} produces the same key for more than one * value in this fluent iterable * @throws NullPointerException if any element of this iterable is {@code null}, or if {@code * keyFunction} produces {@code null} for any key * @since 14.0 */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Apr 02 14:49:41 GMT 2026 - 34.7K bytes - Click Count (0) -
guava/src/com/google/common/collect/FluentIterable.java
* in this fluent iterable to that value * @throws IllegalArgumentException if {@code keyFunction} produces the same key for more than one * value in this fluent iterable * @throws NullPointerException if any element of this iterable is {@code null}, or if {@code * keyFunction} produces {@code null} for any key * @since 14.0 */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Apr 02 14:49:41 GMT 2026 - 34.7K bytes - Click Count (0)