- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 388 for finishes (0.44 sec)
-
pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go
// Defer operations are executed in Last-In is First-Out order. In this case // the lock is acquired first when operationCompletes begins, and is // released when the method finishes, after the lock is released cond is // signaled to wake waiting goroutine. defer grm.cond.Signal() grm.lock.Lock() defer grm.lock.Unlock() if *err == nil || !grm.exponentialBackOffOnError {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 12.6K bytes - Viewed (0) -
tensorflow/compiler/jit/device_compiler_test.cc
fn.set_name("foo"); // Using a mock here to determine when the async compilation finishes. This is // to avoid using absl::SleepFor(). // `RegisterCompilation` is the last call that happens just before the async // compilation completes. We use the completion of this call to determine when // the compilation finshes to verify expected behavior. Notification done; EXPECT_CALL(*mock_profiler_,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Mar 12 06:33:33 UTC 2024 - 19.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
// serveHTTPComplete is channel that is closed/selected when "websocket#ServeHTTP" finishes. serveHTTPComplete := make(chan struct{}) // Ensure panic in spawned goroutine is propagated into the parent goroutine. panicChan := make(chan any, 1) go func() { // If websocket server returns, propagate panic if necessary. Otherwise, // signal HTTPServe finished by closing "serveHTTPComplete". defer func() { if p := recover(); p != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.5K bytes - Viewed (0) -
src/net/cgo_unix.go
// context is cancellable. It is intended for use with calls that don't support context // cancellation (cgo, syscalls). blocking func may still be running after this function finishes. // For the duration of the execution of the blocking function, the thread is 'acquired' using [acquireThread], // blocking might not be executed when the context gets canceled early.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 11.4K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.h
// return a bad status the caller must run all of the `Join`s or any future // `StartExecute`s will deadlock). // // If `is_async=false` (constructor argument), `cancellation_manager` must // live until `Join` finishes. If `is_async=true` it must live until `Join` is // followed by `TFE_ContextAsyncWait` to clear pending operations. It will be // used to cancel all other operations if any fails. //
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 25 15:21:13 UTC 2023 - 12.9K bytes - Viewed (0) -
docs/en/docs/advanced/custom-response.md
1. This is the generator function. It's a "generator function" because it contains `yield` statements inside. 2. By using a `with` block, we make sure that the file-like object is closed after the generator function is done. So, after it finishes sending the response. 3. This `yield from` tells the function to iterate over that thing named `file_like`. And then, for each part iterated, yield that part as coming from this generator function.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 11.7K bytes - Viewed (0) -
platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/steps/AssignImmutableWorkspaceStep.java
* inconsistent), then a unique temporary workspace directory is provided to the work to create its outputs * in, and the work is executed.</li> * <li>When the execution of the work finishes, we snapshot the outputs of the work, and store their hashes * in the {code metadata.bin} file in the temporary workspace directory.</li> * <li>We then attempt to move the temporary workspace directory (including the newly generated
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 19 16:44:11 UTC 2024 - 19.7K bytes - Viewed (0) -
docs/en/docs/tutorial/dependencies/dependencies-with-yield.md
```Python with open("./somefile.txt") as f: contents = f.read() print(contents) ``` Underneath, the `open("./somefile.txt")` creates an object that is called a "Context Manager". When the `with` block finishes, it makes sure to close the file, even if there were exceptions. When you create a dependency with `yield`, **FastAPI** will internally create a context manager for it, and combine it with some other related tools.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Feb 24 23:06:37 UTC 2024 - 14.1K bytes - Viewed (0) -
src/net/tcpsock.go
} return nil } // SetLinger sets the behavior of Close on a connection which still // has data waiting to be sent or to be acknowledged. // // If sec < 0 (the default), the operating system finishes sending the // data in the background. // // If sec == 0, the operating system discards any unsent or // unacknowledged data. // // If sec > 0, the data is sent in the background as with sec < 0.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 13.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go
// safe for use from multiple threads. It returns a timer for backoff, and caller shall backoff // until Timer.C() drains. If the second Backoff() is called before the timer from the first // Backoff() call finishes, the first timer will NOT be drained and result in undetermined // behavior. Backoff() clock.Timer } // Deprecated: Will be removed when the legacy polling functions are removed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 16.5K bytes - Viewed (0)