- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for getExecutor (0.57 sec)
-
tensorflow/c/experimental/stream_executor/stream_executor_test.cc
test_util::PopulateDefaultDeviceFns(&device_fns_); test_util::PopulateDefaultStreamExecutor(&se_); test_util::PopulateDefaultTimerFns(&timer_fns_); } void TearDown() override {} StreamExecutor* GetExecutor(int ordinal) { if (!cplatform_) { cplatform_ = absl::make_unique<CPlatform>( platform_, test_util::DestroyPlatform, platform_fns_, test_util::DestroyPlatformFns, device_fns_, se_, timer_fns_);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon May 20 19:54:04 UTC 2024 - 26.5K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor.cc
} absl::StatusOr<StreamExecutor*> CPlatform::ExecutorForDevice(int ordinal) { stream_executor::StreamExecutorConfig config; config.ordinal = ordinal; return GetExecutor(config); } absl::StatusOr<StreamExecutor*> CPlatform::GetExecutor( const StreamExecutorConfig& config) { return executor_cache_.GetOrCreate( config, [&]() { return GetUncachedExecutor(config); }); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 27.1K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
ManagedScheduledExecutor createScheduled(String displayName, int fixedSize) { throw new UnsupportedOperationException() } } } Executor getExecutor() { return new Executor() { void execute(Runnable runnable) { startThread(runnable) } } } TestThread startThread(Runnable cl) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
private final SyncPoint syncPoint = new SyncPoint(); /** * Creates an Executor which the test can control. */ protected ExecutorService getExecutor() { if (executor == null) { executor = new ExecutorImpl(); } return executor; } /** * Creates an ExecutorFactory for the test to use. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/fixtures/ToolingApiSpec.groovy
import javax.inject.Inject @SelfType(AbstractIntegrationSpec) trait ToolingApiSpec { ToolingApiBackedGradleExecuter getToolingApiExecutor() { return (ToolingApiBackedGradleExecuter) getExecuter() } TestFile getProjectDir() { temporaryFolder.testDirectory } BuildTestFile singleProjectBuildInRootDir(String projectName, @DelegatesTo(BuildTestFile) Closure cl = {}) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 15.1K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
this.hostAlias = hostAlias; } protected BlockingHttpServer(HttpServer server, int timeoutMs, Scheme scheme) { this.server = server; this.server.setExecutor(EXECUTOR_SERVICE); this.serverId = COUNTER.incrementAndGet(); this.handler = new ChainingHttpHandler(lock, timeoutMs, COUNTER, new MustBeRunning()); this.context = server.createContext("/", handler);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/AbstractIntegrationSpec.groovy
private GradleExecuter executor private boolean ignoreCleanupAssertions private boolean enableProblemsApiCheck = false private BuildOperationsFixture buildOperationsFixture = null GradleExecuter getExecuter() { if (executor == null) { executor = createExecuter() if (ignoreCleanupAssertions) { executor.ignoreCleanupAssertions() } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:07:53 UTC 2024 - 32.9K bytes - Viewed (0)