- Sort Score
- Result 10 results
- Languages All
Results 41 - 48 of 48 for unblocksig (0.26 sec)
-
pkg/controller/garbagecollector/graph_builder.go
// After that it is safe to start them here, before that it is not. informersStarted <-chan struct{} // stopCh drives shutdown. When a receive from it unblocks, monitors will shut down. // This channel is also protected by monitorLock. stopCh <-chan struct{} // running tracks whether Run() has been called. // it is protected by monitorLock. running bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
counter.Add(1) // account for the following goroutine go func() { defer counter.Add(-1) // account completion of this goroutine clk.Sleep(time.Second) expectQNCounts(2, 0, 1) // account for unblocking the goroutine that waits on cancelation counter.Add(1) cancel2() }() req2, idle2a := qs.StartRequest(ctx2, &fcrequest.WorkEstimate{InitialSeats: 1}, 2, "", "fs2", "test", "two", queueNoteFn(2))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0) -
src/runtime/trace.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Go execution tracer. // The tracer captures a wide range of execution events like goroutine // creation/blocking/unblocking, syscall enter/exit/block, GC-related events, // changes of heap size, processor start/stop, etc and writes them to a buffer // in a compact form. A precise nanosecond-precision timestamp and a stack
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
interrupted = true; } } } finally { if (interrupted) { Thread.currentThread().interrupt(); } } } /** Unblocks all threads and runs all listeners. */ private static void complete(AbstractFuture<?> param, boolean callInterruptTask) { // Declare a "true" local variable so that the Checker Framework will infer nullness.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
interrupted = true; } } } finally { if (interrupted) { Thread.currentThread().interrupt(); } } } /** Unblocks all threads and runs all listeners. */ private static void complete(AbstractFuture<?> param, boolean callInterruptTask) { // Declare a "true" local variable so that the Checker Framework will infer nullness.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
tensorflow/compiler/mlir/lite/stablehlo/transforms/legalize_hlo.cc
}; // Removes the `mhlo.custom_call @shape_assertion` custom call which represents // an assertion that the first operand (`assert_what`) evaluates to `true`. // This is a temporary workaround for unblocking dynamic model conversion // because starting from version 7, in presence of shape polymorphism JAX will // emit stablehlo.custom_call @shape_assertion to verify at compile time that
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 154.9K bytes - Viewed (0) -
src/net/http/h2_bundle.go
// larger struct and have the Mutex and Cond's memory in the same // allocation. func (cw *http2closeWaiter) Init() { *cw = make(chan struct{}) } // Close marks the closeWaiter as closed and unblocks any waiters. func (cw http2closeWaiter) Close() { close(cw) } // Wait waits for the closeWaiter to become closed. func (cw http2closeWaiter) Wait() { <-cw }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
src/runtime/proc.go
if mp == &m0 { // This is the main thread. Just wedge it. // // On Linux, exiting the main thread puts the process // into a non-waitable zombie state. On Plan 9, // exiting the main thread unblocks wait even though // other threads are still running. On Solaris we can // neither exitThread nor return from mstart. Other // bad things probably happen on other platforms. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0)