- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for executor (0.05 sec)
-
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) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K 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 {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 75.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
setUp(protocol) server.enqueue(MockResponse(body = "A")) server.enqueue(MockResponse(body = "A")) val executor = Executors.newCachedThreadPool(threadFactory("HttpOverHttp2Test")) val countDownLatch = CountDownLatch(2) executor.execute(AsyncRequest("/r1", countDownLatch)) executor.execute(AsyncRequest("/r2", countDownLatch)) countDownLatch.await() assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 73.4K bytes - Viewed (0) -
.bazelrc
# END TF TEST SUITE OPTIONS # START CROSS-COMPILE CONFIGS # Set execution platform to Linux x86 # Note: Lot of the "host_" flags such as "host_cpu" and "host_crosstool_top" # flags seem to be actually used to specify the execution platform details. It # seems it is this way because these flags are old and predate the distinction # between host and execution platform. build:cross_compile_base --config=clang_local
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Fri Aug 22 21:03:34 UTC 2025 - 56K bytes - Viewed (0) -
tensorflow/BUILD
visibility = ["//visibility:public"], win_def_file = ":tensorflow_filtered_def_file", ) # To avoid duplication, check that the C++ or python library does not depend on # the stream executor cuda plugins. Targets that want to use cuda APIs should # instead depend on the dummy plugins in //tensorflow/compiler/xla/tsl/platform/default/build_config # and use header only targets.
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Thu Aug 28 19:11:51 UTC 2025 - 53.4K bytes - Viewed (0) -
android/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}
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 51.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
* .build(); * Response response = eagerClient.newCall(request).execute(); * ``` * * ## Shutdown Isn't Necessary * * The threads and connections that are held will be released automatically if they remain idle. But * if you are writing a application that needs to aggressively release unused resources you may do * so. * * Shutdown the dispatcher's executor service with [shutdown()][ExecutorService.shutdown]. This will
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 51.7K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
implementation("org.bouncycastle:bcprov-jdk15on:1.60") implementation("org.conscrypt:conscrypt-openjdk-uber:1.4.0") implementation("com.squareup.okio:okio:1.15.0") ``` * Fix: Handle dispatcher executor shutdowns gracefully. When there aren't any threads to carry a call its callback now gets a `RejectedExecutionException`. * Fix: Don't permanently cache responses with `Cache-Control: immutable`. We misunderstood the
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
src/main/resources/fess_config.properties
# Template for data crawler job title. job.template.title.data=Data Crawler - {0} # Script template for job execution. job.template.script=return container.getComponent("crawlJob").logLevel("info").webConfigIds([{0}] as String[]).fileConfigIds([{1}] as String[]).dataConfigIds([{2}] as String[]).jobExecutor(executor).execute(); # Maximum number of crawler processes. job.max.crawler.processes=0 # Default script language for jobs.
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 05 14:45:37 UTC 2025 - 54.7K bytes - Viewed (0) -
cmd/test-utils_test.go
// // User-Agent: // // This is ignored from signing because signing this causes problems with generating pre-signed URLs // (that are executed by other agents) or when customers pass requests through proxies, which may // modify the user-agent. // // Authorization: // // Is skipped for obvious reasons var ignoredHeaders = map[string]bool{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0)