- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for collectOneValue (0.08 sec)
-
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* cancelled. For details on when this is called, see {@link #collectOneValue}. */ private void collectValueFromNonCancelledFuture(int index, Future<? extends InputT> future) { try { // We get the result, even if collectOneValue is a no-op, so that we can fail fast. // We use getUninterruptibly over getDone as a micro-optimization, we know the future is done. collectOneValue(index, getUninterruptibly(future));
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 16.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CollectionFuture.java
// Populate the results list with null initially. for (int i = 0; i < futures.size(); ++i) { values.add(null); } this.values = values; } @Override final void collectOneValue(int index, @ParametricNullness V returnValue) { @RetainedLocalRef List<@Nullable Present<V>> localValues = values; if (localValues != null) { localValues.set(index, new Present<>(returnValue)); } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 3.9K bytes - Viewed (0)