Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for executor (0.08 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  2. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  3. tensorflow/c/eager/c_api_test.cc

        if (state.iterations() >= state.max_iterations && async) {
          TFE_Executor* executor = TFE_ContextGetExecutorForThread(ctx);
          TFE_ExecutorWaitForAllPendingNodes(executor, status);
          ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
          TFE_DeleteExecutor(executor);
        }
      }
      TFE_DeleteOp(matmul);
      TFE_DeleteTensorHandle(m);
      TFE_DeleteContext(ctx);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Aug 03 20:50:20 UTC 2023
    - 94.6K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

        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().sequenceNumber).isEqualTo(0)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  5. .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 --host_cpu=k8
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 28 22:02:31 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  6. 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 @local_tsl//tsl/platform/default/build_config
    # and use header only targets.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Oct 16 05:28:35 UTC 2024
    - 53.5K bytes
    - Viewed (0)
  7. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 52K bytes
    - Viewed (0)
  8. okhttp/src/main/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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  9. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  10. 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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
Back to top