- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for execute (0.18 sec)
-
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
public <Request extends ActionRequest, Response extends ActionResponse> ActionFuture<Response> execute( final ActionType<Response> action, final Request request) { return client.execute(action, request); } @Override public <Request extends ActionRequest, Response extends ActionResponse> void execute(final ActionType<Response> action,
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 84.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
@CheckForNull // null only for TOMBSTONE final Executor executor; // writes to next are made visible by subsequent CAS's on the listeners field @CheckForNull Listener next; Listener(Runnable task, Executor executor) { this.task = task; this.executor = executor; } Listener() { this.task = null; this.executor = null; } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
executor.execute(task); return task; } /** * Executes {@code runnable} on the specified {@code executor}, returning a {@code Future} that * will complete after execution. * * @throws RejectedExecutionException if the task cannot be scheduled for execution * @since 28.2 */ public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
} ExecutorService createExecutor(int parallelism) { // // We need an executor that will not block. // We can't use work stealing, as we are building a graph // and this could lead to cycles where a thread waits for // a task to finish, then execute another one which waits // for the initial task...
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 56.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/json/SearchApiManager.java
if (ComponentUtil.getFessConfig().isSuggestDocuments()) { builder.addKind(SuggestItem.Kind.DOCUMENT.toString()); } final SuggestResponse suggestResponse = builder.execute().getResponse(); buf.append("\"query_time\":").append(suggestResponse.getTookMs()); buf.append(",\"record_count\":").append(suggestResponse.getTotal());
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 02:17:23 GMT 2024 - 50.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/MavenProject.java
this.artifacts = null; this.artifactMap = null; } /** * Sets the scope filter to select the artifacts being exposed to the currently executed mojo. * <strong>Warning:</strong> This is an internal utility method that is only public for technical reasons, it is not
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Mar 01 17:18:13 GMT 2024 - 56.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
} try { closingFuture.finishToValueAndCloser(new NoOpValueAndCloserConsumer<>(), executor); fail(); } catch (IllegalStateException expected) { } } // Avoid infinite recursion if a closeable's close() method throws RejectedExecutionException and // is closed using the direct executor. public void testCloseThrowsRejectedExecutionException() throws Exception {
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) -
guava/src/com/google/common/cache/CacheBuilder.java
* href="https://www.javadoc.io/doc/com.github.ben-manes.caffeine/caffeine/latest/com.github.benmanes.caffeine/com/github/benmanes/caffeine/cache/AsyncCacheLoader.html#asyncLoad(K,java.util.concurrent.Executor)">{@code * AsyncCacheLoader.asyncLoad}</a> must return a {@code CompletableFuture}. Users of Guava's {@link * com.google.common.util.concurrent.ListenableFuture} can adapt between the two {@code Future}
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 51.3K bytes - Viewed (0)