- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 48 for unblocksig (0.25 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/interface.go
// Get reads the current value of this variable. If this // variable is not set yet then this call blocks until this // variable gets a value. Get() interface{} // Set normally writes a value into this variable, unblocks every // goroutine waiting for this variable to have a value, and // returns true. In the unhappy case that this variable is // already set, this method returns false without modifying the // variable's value.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 10 14:37:53 UTC 2021 - 1.2K bytes - Viewed (0) -
src/internal/poll/fd_poll_runtime.go
return nil } func (pd *pollDesc) close() { if pd.runtimeCtx == 0 { return } runtime_pollClose(pd.runtimeCtx) pd.runtimeCtx = 0 } // Evict evicts fd from the pending list, unblocking any I/O running on fd. func (pd *pollDesc) evict() { if pd.runtimeCtx == 0 { return } runtime_pollUnblock(pd.runtimeCtx) } func (pd *pollDesc) prepare(mode int, isFile bool) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:59 UTC 2024 - 4.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java
private OverflowAvoidingLockSupport() {} static void parkNanos(@CheckForNull Object blocker, long nanos) { // Even in the extremely unlikely event that a thread unblocks itself early after only 68 years, // this is indistinguishable from a spurious wakeup, which LockSupport allows. LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 1.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java
private OverflowAvoidingLockSupport() {} static void parkNanos(@CheckForNull Object blocker, long nanos) { // Even in the extremely unlikely event that a thread unblocks itself early after only 68 years, // this is indistinguishable from a spurious wakeup, which LockSupport allows. LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/counter/interface.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 12 16:12:48 UTC 2019 - 1.4K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/futile-wakeup.go
// license that can be found in the LICENSE file. // Tests to make sure the runtime doesn't generate futile wakeups. For example, // it makes sure that a block on a channel send that unblocks briefly only to // immediately go back to sleep (in such a way that doesn't reveal any useful // information, and is purely an artifact of the runtime implementation) doesn't // make it into the trace. //go:build ignore
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.8K bytes - Viewed (0) -
src/runtime/trace/trace.go
// for the Go execution tracer. // // # Tracing runtime activities // // The execution trace captures a wide range of execution events such as // goroutine creation/blocking/unblocking, syscall enter/exit/block, // GC-related events, changes of heap size, processor start/stop, etc. // When CPU profiling is active, the execution tracer makes an effort to // include those samples as well.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 20 00:47:09 UTC 2023 - 5.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/CleanUpVirtualFileSystemAfterBuild.java
import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; /** * Asynchronously cleans up the VFS after a build. * * Unblocks the client to receive the build finished event while the cleanup is happening. * However, the next build is not allowed to start until the cleanup is finished. */ @NonNullApi
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 4K bytes - Viewed (0) -
src/net/fd_unix.go
ret = mapErr(ctxErr) fd.Close() // prevent a leak } }() go func() { select { case <-ctxDone: // Force the runtime's poller to immediately give up // waiting for writability, unblocking waitWrite // below. fd.pfd.SetWriteDeadline(aLongTimeAgo) testHookCanceledDial() interruptRes <- ctx.Err() case <-done: interruptRes <- nil } }() } for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 20:19:46 UTC 2023 - 5.4K bytes - Viewed (0) -
internal/lock/lock_test.go
t.Error(blerr) return } locked <- struct{}{} if blerr = bl.Close(); blerr != nil { t.Error(blerr) return } }() select { case <-locked: t.Error("unexpected unblocking") case <-time.After(100 * time.Millisecond): } // unlock if err = dupl.Close(); err != nil { t.Fatal(err) } // the previously blocked routine should be unblocked select {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 3.6K bytes - Viewed (0)