- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 1,209 for executors (0.14 sec)
-
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
} public void testNoOpScheduledExecutorShutdown() { ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); assertFalse(executor.isShutdown()); assertFalse(executor.isTerminated()); executor.shutdown(); assertTrue(executor.isShutdown()); assertTrue(executor.isTerminated()); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.7K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_host_send_recv_device_context_test.cc
stream_executor::StreamExecutor* executor = platform->ExecutorForDevice(0).value(); TF_ASSERT_OK_AND_ASSIGN(auto stream, executor->CreateStream()); se::DeviceMemoryBase gpu_dst{device_tensor.data(), 4 * sizeof(float)}; xla::Shape shape; TF_ASSERT_OK(TensorShapeToXLAShape(DT_FLOAT, TensorShape({2, 2}), &shape)); TF_ASSERT_OK_AND_ASSIGN(auto se_event, executor->CreateEvent());
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 22:46:36 UTC 2024 - 7.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ImmediateFuture.java
public void addListener(Runnable listener, Executor executor) { checkNotNull(listener, "Runnable was null."); checkNotNull(executor, "Executor was null."); try { executor.execute(listener); } catch (Exception e) { // sneaky checked exception // ListenableFuture's contract is that it will not throw unchecked exceptions, so log the bad // runnable and/or executor and swallow it. log.get() .log(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 3.5K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/connection/ParameterizedActionRunner.java
private final InternalParameterAcceptingConnection executor; ParameterizedActionRunner(InternalParameterAcceptingConnection executor, CancellationExceptionTransformer exceptionTransformer, VersionDetails versionDetails) { super(null, exceptionTransformer, versionDetails); this.executor = executor; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:05 UTC 2024 - 1.7K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/connection/CancellableActionRunner.java
private final InternalCancellableConnection executor; private final CancellationExceptionTransformer exceptionTransformer; private final VersionDetails versionDetails; CancellableActionRunner(InternalCancellableConnection executor, CancellationExceptionTransformer exceptionTransformer, VersionDetails versionDetails) { this.executor = executor; this.exceptionTransformer = exceptionTransformer;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:05 UTC 2024 - 3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectAllRequestsThenReleaseAll.java
import java.util.Collection; import java.util.concurrent.Executor; import java.util.concurrent.locks.Lock; class ExpectAllRequestsThenReleaseAll extends ExpectMaxNConcurrentRequestsThenRelease { ExpectAllRequestsThenReleaseAll(Lock lock, int testId, Duration timeout, WaitPrecondition previous, Collection<? extends ResourceExpectation> expectations, Executor executor) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/DefaultTestLauncherTest.groovy
import org.gradle.tooling.internal.protocol.ResultHandlerVersion1 import spock.lang.Specification class DefaultTestLauncherTest extends Specification { def executor = Mock(AsyncConsumerActionExecutor) def connection = Mock(ConsumerConnection) def launcher = new DefaultTestLauncher(executor, Stub(ConnectionParameters)) def "adding tests does not affect an operation in progress"() { given: launcher.withJvmTestClasses("test")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 5.4K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNRequestsThenReleaseOne.java
import java.util.Collection; import java.util.concurrent.Executor; import java.util.concurrent.locks.Lock; public class ExpectMaxNRequestsThenReleaseOne extends ExpectMaxNConcurrentRequestsThenRelease { public ExpectMaxNRequestsThenReleaseOne(Lock lock, int testId, Duration timeout, int maxConcurrent, WaitPrecondition previous, Collection<? extends ResourceExpectation> expectedRequests, Executor executor) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/api/v1/tf_dialect_to_executor.h
namespace tf2xla { namespace v1 { // Given the input Module op that's in the Tensorflow Dialect, convert the MLIR // module in place to the Tensorflow Executor Dialect. Returns an OK Status if // success, otherwise failure with an error message. // The Tensorflow Executor Dialect is required to export an MLIR module to a // Tensorflow GraphDef. This API will add control dependencies and verify that
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Oct 11 18:45:46 UTC 2023 - 2.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/api/v2/tf_dialect_to_executor.h
// module in place to the Tensorflow Executor Dialect. Returns an OK Status if // success, otherwise failure with an error message. // The Tensorflow Executor Dialect is required to export an MLIR module to a // Tensorflow GraphDef. This API will add control dependencies and verify that // the conversion was successful. // // This also converts the Tensorflow Dialect MLIR into the Tensorflow Executor
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Oct 03 23:19:33 UTC 2023 - 2.2K bytes - Viewed (0)