- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 1,092 for Execute (0.05 seconds)
-
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
* Callable}. * * @param callable the callable task * @since 10.0 */ public static <V extends @Nullable Object> ListenableFutureTask<V> create(Callable<V> callable) { return new ListenableFutureTask<>(callable); } /** * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@code
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 10 11:51:21 GMT 2026 - 4.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* it is invoked using this executor once the future's computation is {@linkplain Future#isDone() * complete}. If the computation has already completed when the listener is added, the listener will * execute immediately. * * <p>See the Guava User Guide article on <a * href="https://github.com/google/guava/wiki/ListenableFutureExplained">{@code * ListenableFuture}</a>. * * <p>This class is GWT-compatible. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
logger.debug("Process {} is already executed.", p); } } } /** * Checks if the destroyer has been executed. * @return True if executed, false otherwise. */ public boolean isExecuted() { return executed.get(); } } /**
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jan 01 12:47:47 GMT 2026 - 16.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ExecutorService delegate = mock(ExecutorService.class); ListeningExecutorService service = listeningDecorator(delegate); Runnable task = () -> {}; service.execute(task); verify(delegate).execute(task); } public void testListeningDecorator_scheduleSuccess() throws Exception { CountDownLatch completed = new CountDownLatch(1); ScheduledThreadPoolExecutor delegate =
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/log/AdminLogAction.java
*/ @Execute @Secured({ ROLE, ROLE + VIEW }) public HtmlResponse index() { return asIndexHtml(); } /** * Downloads a log file by its encoded ID. * * @param id the Base64 encoded filename of the log file to download * @return ActionResponse containing the log file stream */ @Execute @Secured({ ROLE, ROLE + VIEW })Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Jan 23 23:57:26 GMT 2026 - 5.8K bytes - Click Count (0) -
src/main/java/org/codelibs/core/sql/StatementUtil.java
protected StatementUtil() { } /** * Executes the SQL. * * @param statement * {@link Statement}. Must not be {@literal null}. * @param sql * SQL string. Must not be {@literal null} or empty. * @return The result of the execution. * @see Statement#execute(String) */ public static boolean execute(final Statement statement, final String sql) {
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
assertThat(task).isInstanceOf(WrappedRunnable.class); return inline.submit(task, result); } @Override public void execute(Runnable command) { lastMethodCalled = "execute"; assertThat(command).isInstanceOf(WrappedRunnable.class); inline.execute(command); } private static <T> void assertTaskWrapped(Collection<? extends Callable<T>> tasks) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 10.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/ExecJob.java
protected abstract String getExecuteType(); /** * Executes the job with the specified job executor. * This method sets the job executor and then calls the abstract execute method. * * @param jobExecutor the job executor to use for execution * @return the execution result message or summary */ public String execute(final JobExecutor jobExecutor) { jobExecutor(jobExecutor);
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 14.2K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/CacheResponse.kt
fun run() { val request = Request .Builder() .url("http://publicobject.com/helloworld.txt") .build() val response1Body = client.newCall(request).execute().use { if (!it.isSuccessful) throw IOException("Unexpected code $it") println("Response 1 response: $it") println("Response 1 cache response: ${it.cacheResponse}")
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/cache/CacheAction.java
// ============== /** * Retrieves and displays cached content for a specific document. * * @param form the cache form containing document ID and highlight query * @return ActionResponse containing the cached document content or error redirect */ @ExecuteCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 3.9K bytes - Click Count (0)