- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 2,355 for nwait (0.05 sec)
-
subprojects/core/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationQueueTest.groovy
operationQueue.waitForCompletion() } }) waitForCompletionThread.start() and: // wait for operations to begin running startedLatch.await(30, TimeUnit.SECONDS) and: operationQueue.cancel() and: // release the running operations to complete releaseLatch.countDown()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 9.4K bytes - Viewed (0) -
src/syscall/exec_plan9.go
if n > 0 { err = NewError(string(errbuf[:n])) } else if err == nil { err = NewError("failed to read exec status") } // Child failed; wait for it to exit, to make sure // the zombies don't accumulate. for wmsg.Pid != pid { Await(&wmsg) } return 0, err } // Read got EOF, so pipe closed on exec, so exec succeeded. return pid, nil } type waitErr struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 13.3K bytes - Viewed (0) -
platforms/jvm/plugins-application/src/integTest/groovy/org/gradle/internal/deployment/JavaApplicationDeploymentIntegrationTest.groovy
writer.println(Message.message + " > " + arg); } writer.close(); // wait forever new File(args[1]).createNewFile(); new CountDownLatch(1).await(10, TimeUnit.MINUTES); } } """ messageSrc = file("src/main/java/org/gradle/deployment/Message.java") << """
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 08 04:59:12 UTC 2024 - 4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/plan9/syscall_plan9.go
func (w Waitmsg) ExitStatus() int { if len(w.Msg) == 0 { // a normal exit returns no message return 0 } return 1 } //sys await(s []byte) (n int, err error) func Await(w *Waitmsg) (err error) { var buf [512]byte var f [5][]byte n, err := await(buf[:]) if err != nil || w == nil { return } nf := 0 p := 0 for i := 0; i < n && nf < len(f)-1; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 16 22:24:28 UTC 2022 - 7K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/DefaultWorkerExecutor.java
workItems.add(workerExecutor.submitWork(workActionClass, parameterAction, spec, workerFactory)); } @Override public void await() throws WorkerExecutionException { workerExecutor.await(workItems); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:17:07 UTC 2024 - 15.2K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerExecutorNestingIntegrationTest.groovy
childSubmissions = this.childSubmissions } } if (waitForChildren) { executor.await() } } } """.stripIndent() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 9.5K bytes - Viewed (0) -
src/os/exec/exec_test.go
var wg sync.WaitGroup wg.Add(1) defer wg.Wait() go func() { defer wg.Done() _, err := io.Copy(stdin, strings.NewReader(stdinCloseTestString)) check("Copy", err) // Before the fix, this next line would race with cmd.Wait. if err := stdin.Close(); err != nil && !errors.Is(err, os.ErrClosed) { t.Errorf("Close: %v", err) } }() check("Wait", cmd.Wait()) } // Issue 17647.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 48.4K bytes - Viewed (0) -
src/cmd/go/testdata/script/goroot_executable_trimpath.txt
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 21 22:16:54 UTC 2024 - 3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
public @Nullable Void call() throws InterruptedException { running = true; startLatch.countDown(); stopLatch.await(); running = false; return null; } public void waitForStart() throws InterruptedException { startLatch.await(); } public void stop() { stopLatch.countDown(); } public boolean isRunning() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 16.8K bytes - Viewed (0)