- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 51 for Wain (0.12 sec)
-
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* href="https://github.com/google/guava/wiki/ListenableFutureExplained">{@code * ListenableFuture}</a>. * * <p>This class is GWT-compatible. * * <h3>Purpose</h3> * * <p>The main purpose of {@code ListenableFuture} is to help you chain together a graph of * asynchronous operations. You can chain them together manually with calls to methods like {@link
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
@Override public void run() { notifyStarted(); // We need to wait for the main thread to leave the ServiceManager.startAsync call // to // ensure that the thread running the failure callbacks is not the main thread. Uninterruptibles.awaitUninterruptibly(afterStarted); notifyFailed(new Exception("boom")); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
* impossible. We want the test, though, in case that changes in the future, * so we use isInstance instead. */ assertFalse( "Can't test the main listenInPoolThread path " + "if the input is already a ListenableFuture", ListenableFuture.class.isInstance(input)); ListenableFuture<String> listenable = listenInPoolThread(input); /*
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 9.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionError.java
/* * Ideally, this class would have exposed only constructors that require a non-null cause. See * https://github.com/jspecify/jspecify-reference-checker/blob/61aafa4ae52594830cfc2d61c8b113009dbdb045/src/main/java/com/google/jspecify/nullness/NullSpecTransfer.java#L789 * and https://github.com/jspecify/jspecify/issues/490. * * (That would also have ensured that its cause was always an Error, rather than possibly another
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Mar 07 17:52:19 GMT 2024 - 3.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Platform.java
* would declare a return type of `@Nullable T[]`. However, we've decided not to think too hard * about arrays for now, as they're a mess. (We previously discussed this in the review of * ObjectArrays, which is the main caller of this method.) */ static <T extends @Nullable Object> T[] newArray(T[] reference, int length) { T[] empty = reference.length == 0 ? reference : Arrays.copyOf(reference, 0);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 4.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
new CyclicBarrier( 6 // for the setter threads + 50 // for the listeners + 50 // for the blocking get threads, + 1); // for the main thread final ExecutorService executor = Executors.newFixedThreadPool(barrier.getParties()); final AtomicReference<AbstractFuture<String>> currentFuture = Atomics.newReference();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* * <p>Here is a simple example of how to use a {@code ServiceManager} to start a server. * * <pre>{@code * class Server { * public static void main(String[] args) { * Set<Service> services = ...; * ServiceManager manager = new ServiceManager(services); * manager.addListener(new Listener() { * public void stopped() {}
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 30.5K bytes - Viewed (0) -
android/guava/src/com/google/common/reflect/ClassPath.java
} } /** * Returns the class path URIs specified by the {@code Class-Path} manifest attribute, according * to <a * href="http://docs.oracle.com/javase/8/docs/technotes/guides/jar/jar.html#Main_Attributes">JAR * File Specification</a>. If {@code manifest} is null, it means the jar file has no manifest, and * an empty set will be returned. */ @VisibleForTesting
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Jan 05 17:43:40 GMT 2022 - 24.9K bytes - Viewed (1) -
guava/src/com/google/common/collect/CollectSpliterators.java
} } /** * Implementation of {@link Stream#flatMap} with an object spliterator output type. * * <p>To avoid having this type, we could use {@code FlatMapSpliterator} directly. The main * advantages to having the type are the ability to use its constructor reference below and the * parallelism with the primitive version. In short, it makes its caller ({@code flatMap}) * simpler. *
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Feb 19 15:21:23 GMT 2024 - 19.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Cut.java
private BelowAll() { /* * No code ever sees this bogus value for `endpoint`: This class overrides both methods that * use the `endpoint` field, compareTo() and endpoint(). Additionally, the main implementation * of Cut.compareTo checks for belowAll before reading accessing `endpoint` on another Cut * instance. */ super(""); } @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 12.3K bytes - Viewed (0)