- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 164 for submit (0.93 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
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; for (int j = 0; j < getsPerTask; j++) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 4.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java
public class ClosingFutureFinishToFutureTest extends AbstractClosingFutureTest { public void testFinishToFuture_throwsIfCalledTwice() throws Exception { ClosingFuture<Closeable> closingFuture = ClosingFuture.submit( new ClosingCallable<Closeable>() { @Override public Closeable call(DeferredCloser closer) throws Exception { return closer.eventuallyClose(mockCloseable, executor);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
return new NoOpScheduledExecutorService(); } /** * Creates a scheduled executor service that runs each task in the thread that invokes {@code * execute/submit/schedule}, as in {@link CallerRunsPolicy}. This applies both to individually * submitted tasks and to collections of tasks submitted via {@code invokeAll}, {@code invokeAny},
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Callables.java
} /** * Creates an {@link AsyncCallable} from a {@link Callable}. * * <p>The {@link AsyncCallable} returns the {@link ListenableFuture} resulting from {@link * ListeningExecutorService#submit(Callable)}. * * @since 20.0 */ @J2ktIncompatible @GwtIncompatible public static <T extends @Nullable Object> AsyncCallable<T> asAsyncCallable(
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 4.4K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java
for (int i = numberOfThreads; i > 0; i--) { @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored Future<?> possiblyIgnoredError = executorService.submit( new Callable<@Nullable Void>() { @Override public @Nullable Void call() throws Exception { startLatch.countDown(); startLatch.await();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 06 14:40:46 GMT 2024 - 6.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java
ImmutableList<String> keys = ImmutableList.of("a", "b", "c"); try { List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); for (int i = 0; i < nTasks; i++) { futures.add(pool.submit(new MutateTask(multiset, keys))); } int[] deltas = new int[3]; for (Future<int[]> future : futures) { int[] taskDeltas = future.get(); for (int i = 0; i < deltas.length; i++) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 5.8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/MultiThreadedBuilder.java
Callable<ProjectSegment> cb = createBuildCallable( rootSession, projectSegment, reactorContext, taskSegment, muxer, duplicateArtifactIds); service.submit(cb); } // for each finished project for (int i = 0; i < analyzer.getNumberOfBuilds(); i++) { try { ProjectSegment projectBuild = service.take().get();
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Sep 22 09:07:17 GMT 2023 - 9.4K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
@Override public void run() { throw new RuntimeException("Oh no!"); } }; Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable); assertThrows(ExecutionException.class, () -> future.get()); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
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; for (int j = 0; j < getsPerTask; j++) {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 4.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
new TearDown() { @Override public void tearDown() { executor.shutdownNow(); } }); sleeper = new SleepingRunnable(1000); delayedFuture = executor.submit(sleeper, true); tearDownStack.addTearDown( new TearDown() { @Override public void tearDown() { Thread.interrupted(); } }); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.1K bytes - Viewed (0)