- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 2,355 for nwait (0.13 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/CancellationSpec.groovy
cancellationToken.addCallback { latch.countDown() } // Signal to test that callback has been registered ${server.callFromBuild("registered")} // Wait until cancel request received by build process latch.await() """ } void buildWasCancelled(TestResultHandler resultHandler, String failureMessage = 'Could not execute build using') {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 6.1K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
// await until controller.taintedNodes is empty err := wait.PollImmediate(10*time.Millisecond, time.Second, func() (bool, error) { controller.taintedNodesLock.Lock() defer controller.taintedNodesLock.Unlock() _, ok := controller.taintedNodes["node1"] return !ok, nil }) if err != nil { t.Errorf("Failed to await for processing node deleted: %q", err) } cancel() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonReuseIntegrationTest.groovy
client.inputStream.skip(client.inputStream.available()) } client.shutdownOutput() latch.await() // wait for the end of the test before closing the connection println("Closing client ${client.remoteSocketAddress}") } } catch (SocketException e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 10.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:15:24 UTC 2024 - 37.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/runtime_fallback/runtime_fallback_executor.cc
// Space for returned values. llvm::SmallVector<RCReference<AsyncValue>> results(compute->num_results()); compute->Execute(*exec_ctx_, exec_arguments, results); // Wait for the function execution to finish, as well as the side-effects. host_context_->Await(results); // Check that all results are available. llvm::SmallVector<Tensor> ret_values; for (unsigned i = 1; i < results.size(); ++i) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 08 00:18:59 UTC 2024 - 9.1K bytes - Viewed (0) -
docs/es/docs/async.md
# Concurrencia y async / await Detalles sobre la sintaxis `async def` para *path operation functions* y un poco de información sobre código asíncrono, concurrencia y paralelismo. ## ¿Tienes prisa? <abbr title="too long; didn't read"><strong>TL;DR:</strong></abbr> Si estás utilizando libraries de terceros que te dicen que las llames con `await`, del tipo: ```Python results = await some_library() ```
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 24.9K bytes - Viewed (0) -
src/syscall/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 Feb 26 21:03:59 UTC 2024 - 9.4K bytes - Viewed (0) -
cmd/data-scanner.go
// proceed to heal nonetheless, since // this object might be dangling. entry, _ = entries.firstFound() } wait := noWait if f.weSleep() { // wait timer per object. wait = scannerSleeper.Timer(ctx) } defer wait() f.updateCurrentPath(entry.name) stopFn := globalScannerMetrics.log(scannerMetricHealAbandonedObject, f.root, entry.name)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:43:17 UTC 2024 - 47.6K bytes - Viewed (0) -
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)