- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 173 for submit (0.23 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
assertNoExpectedFailures(); super.tearDown(); } public void testFrom() throws Exception { ClosingFuture<String> closingFuture = ClosingFuture.from(executor.submit(Callables.returning(closeable1))) .transform( new ClosingFunction<TestCloseable, String>() { @Override
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 75.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
@GwtIncompatible public static Executor newSequentialExecutor(Executor delegate) { return new SequentialExecutor(delegate); } /** * Creates an {@link ExecutorService} whose {@code submit} and {@code invokeAll} methods submit * {@link ListenableFutureTask} instances to the given delegate executor. Those methods, as well * as {@code execute} and {@code invokeAny}, are implemented in terms of calls to {@code
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
assertNoExpectedFailures(); super.tearDown(); } public void testFrom() throws Exception { ClosingFuture<String> closingFuture = ClosingFuture.from(executor.submit(Callables.returning(closeable1))) .transform( new ClosingFunction<TestCloseable, String>() { @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 74.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
import static com.google.common.util.concurrent.Futures.nonCancellationPropagating; import static com.google.common.util.concurrent.Futures.scheduleAsync; import static com.google.common.util.concurrent.Futures.submit; import static com.google.common.util.concurrent.Futures.submitAsync; import static com.google.common.util.concurrent.Futures.successfulAsList; import static com.google.common.util.concurrent.Futures.transform;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/EventBusTest.java
List<Future<?>> futures = Lists.newArrayList(); ExecutorService executor = Executors.newFixedThreadPool(10); int numberOfCatchers = 10000; for (int i = 0; i < numberOfCatchers; i++) { futures.add(executor.submit(new Registrator(bus, catchers))); } for (int i = 0; i < numberOfCatchers; i++) { futures.get(i).get(); } assertEquals("Unexpected number of catchers in the list", numberOfCatchers, catchers.size());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
List<Future<?>> futures = Lists.newArrayList(); ExecutorService executor = Executors.newFixedThreadPool(10); int numberOfCatchers = 10000; for (int i = 0; i < numberOfCatchers; i++) { futures.add(executor.submit(new Registrator(bus, catchers))); } for (int i = 0; i < numberOfCatchers; i++) { futures.get(i).get(); } assertEquals("Unexpected number of catchers in the list", numberOfCatchers, catchers.size());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/ProjectModelResolver.java
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 15.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/action/FessMessages.java
/** The key of the message: Your request might have been processed before this request. Please check and retry it. */ public static final String ERRORS_APP_DOUBLE_SUBMIT_REQUEST = "{errors.app.double.submit.request}"; /** The key of the message: Username or Password is not correct. */ public static final String ERRORS_login_error = "{errors.login_error}";
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 119.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
import static com.google.common.util.concurrent.Futures.nonCancellationPropagating; import static com.google.common.util.concurrent.Futures.scheduleAsync; import static com.google.common.util.concurrent.Futures.submit; import static com.google.common.util.concurrent.Futures.submitAsync; import static com.google.common.util.concurrent.Futures.successfulAsList; import static com.google.common.util.concurrent.Futures.transform;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
final SearchRequestParams reqParams = new SearchRequestParamsWrapper(params, 0, i == 0 ? windowSize : size); final RankFusionSearcher searcher = searchers[i]; resultList.add(executorService.submit(() -> { try { if (externalContext != null) { requestOpt.ifPresent(externalContext::setRequest);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 16.5K bytes - Viewed (0)