Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for executor (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. .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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top