Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for getExecutor (0.57 sec)

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