- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 4,110 for futures (0.2 sec)
-
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
List<Future<String>> futures = testExecutor.invokeAll(tasks); mock.assertLastMethodCalled("invokeAll"); checkResults(futures); } { MockExecutor mock = new MockExecutor(); TimeUnit unit = TimeUnit.SECONDS; long timeout = 5; TestExecutor testExecutor = new TestExecutor(mock); List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Jan 05 19:41:03 UTC 2023 - 9.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
List<Future<String>> futures = testExecutor.invokeAll(tasks); mock.assertLastMethodCalled("invokeAll"); checkResults(futures); } { MockExecutor mock = new MockExecutor(); TimeUnit unit = TimeUnit.SECONDS; long timeout = 5; TestExecutor testExecutor = new TestExecutor(mock); List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Jan 05 19:41:03 UTC 2023 - 9.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/ir/mlrt/tf_mlrt_ops.td
let summary = "Allocate futures and promsies for tensorflow tensors"; let description = [{ Allocate futures and promsies for tensorflow tensors. $num_futures: The number of futures to be allocated. $promises: There are $num_futures promises. promises[i] shares the state with futures[i]. $futures: There are $num_futures futures. futures[i] shares the state with promises[i]. }];
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 31 20:44:15 UTC 2024 - 13.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
@CanIgnoreReturnValue @ParametricNullness static <V extends @Nullable Object, X extends Exception> V getChecked( Future<V> future, Class<X> exceptionClass) throws X { return getChecked(bestGetCheckedTypeValidator(), future, exceptionClass); } /** Implementation of {@link Futures#getChecked(Future, Class)}. */ @CanIgnoreReturnValue @VisibleForTesting @ParametricNullness
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
* <li>To retrieve a result from a {@code Future} that is already done, use {@link * Futures#getDone Futures.getDone}. * <li>To treat {@link InterruptedException} uniformly with other exceptions, use {@link * Futures#getChecked(Future, Class, long, TimeUnit) Futures.getChecked}. * <li>To get uninterruptibility and remove checked exceptions, use {@link * Futures#getUnchecked}. * </ul> *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 14.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
private final ListenableFuture<@Nullable Void> future; private boolean called = false; private TestCallable(ListenableFuture<@Nullable Void> future) { this.future = future; } @Override public ListenableFuture<@Nullable Void> call() throws Exception { called = true; return future; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 16.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
@CanIgnoreReturnValue @ParametricNullness static <V extends @Nullable Object, X extends Exception> V getChecked( Future<V> future, Class<X> exceptionClass) throws X { return getChecked(bestGetCheckedTypeValidator(), future, exceptionClass); } /** Implementation of {@link Futures#getChecked(Future, Class)}. */ @CanIgnoreReturnValue @VisibleForTesting @ParametricNullness
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 10.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import java.util.concurrent.CancellationException; import java.util.concurrent.Future; import junit.framework.TestCase; /** Unit tests for {@link Futures#getUnchecked(Future)}. */ @GwtCompatible(emulated = true) public class FuturesGetUncheckedTest extends TestCase { public void testGetUnchecked_success() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 4.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import java.util.concurrent.CancellationException; import java.util.concurrent.Future; import junit.framework.TestCase; /** Unit tests for {@link Futures#getUnchecked(Future)}. */ @GwtCompatible(emulated = true) public class FuturesGetUncheckedTest extends TestCase { public void testGetUnchecked_success() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 4.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
final AtomicLongMap<String> map = AtomicLongMap.create(); ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); ArrayList<Future<Long>> futures = new ArrayList<>(); for (int i = 0; i < nTasks; i++) { futures.add( threadPool.submit( new Callable<Long>() { @Override public Long call() { long threadSum = 0;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 4.2K bytes - Viewed (0)