Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for runAsync (0.14 sec)

  1. platforms/enterprise/enterprise/src/integTest/groovy/org/gradle/internal/enterprise/GradleEnterprisePluginBackgroundJobExecutorsIntegrationTest.groovy

        @Override
        String runIgnoringInputs(String code) {
            """
                def executors = ${executors}
                def future = ${CompletableFuture.name}.runAsync({
                    ${code}
                }, executors.userJobExecutor)
    
                // Block until the job completes to ensure it run at the configuration time.
                future.get()
            """
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Feb 29 16:27:53 UTC 2024
    - 7K bytes
    - Viewed (0)
  2. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/CleanUpVirtualFileSystemAfterBuild.java

            }
        }
    
        private CompletableFuture<Void> startAsyncCleanupAfterBuild() {
            return userHomeServiceRegistry.getCurrentServices()
                .map(serviceRegistry ->
                    CompletableFuture.runAsync(() -> {
                        LOGGER.debug("Cleaning virtual file system after build finished");
                        BuildLifecycleAwareVirtualFileSystem virtualFileSystem = serviceRegistry.get(BuildLifecycleAwareVirtualFileSystem.class);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jan 25 15:08:33 UTC 2024
    - 4K bytes
    - Viewed (0)
  3. tensorflow/compiler/jit/kernels/xla_ops.cc

      if (run_synchronous) {
        execution_output =
            executable->Run(std::move(execution_inputs), run_options);
      } else {
        execution_output =
            executable->RunAsync(std::move(execution_inputs), run_options);
      }
    
      auto elapsed = env->NowMicros() - start_time;
      VLOG(2) << "Elapsed time for Xla Executable Run: " << elapsed << "us";
      return execution_output;
    }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri May 17 22:46:36 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  4. fastapi/concurrency.py

        except Exception as e:
            ok = bool(
                await anyio.to_thread.run_sync(
                    cm.__exit__, type(e), e, None, limiter=exit_limiter
                )
            )
            if not ok:
                raise e
        else:
            await anyio.to_thread.run_sync(
                cm.__exit__, None, None, None, limiter=exit_limiter
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Mon Dec 25 17:57:35 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  5. src/cmd/go/internal/workcmd/sync.go

    that in each workspace module.
    
    See the workspaces reference at https://go.dev/ref/mod#workspaces
    for more information.
    `,
    	Run: runSync,
    }
    
    func init() {
    	base.AddChdirFlag(&cmdSync.Flag)
    	base.AddModCommonFlags(&cmdSync.Flag)
    }
    
    func runSync(ctx context.Context, cmd *base.Command, args []string) {
    	modload.ForceUseModules = true
    	modload.InitWorkfile()
    	if modload.WorkFilePath() == "" {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat Jun 03 21:13:11 UTC 2023
    - 4.6K bytes
    - Viewed (0)
  6. samples/bookinfo/src/productpage/static/tailwind/tailwind.css

    urn this._run(r,n).then(function(a){return a.root})},e.astSync=function(r,n){return this._runSync(r,n).root},e.transform=function(r,n){return this._run(r,n).then(function(a){return a.transform})},e.transformSync=function(r,n){return this._runSync(r,n).transform},e.process=function(r,n){return this._run(r,n).then(function(a){return a.string||a.root.toString()})},e.processSync=function(r,n){var a=this._runSync(r,n);return a.string||a.root.toString()},i}();Wr.default=Dk;vp.exports=Wr.default});var kp=v(G=>{l();"use...
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 28 14:48:01 UTC 2024
    - 357.1K bytes
    - Viewed (0)
Back to top