- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 88 for Signalfd (0.12 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java
// TODO: Test hasQueuedThreads(). // TODO: Test getWaitQueueLength(Guard). // TODO: Test automatic signaling before leave, waitFor, and reentrant enterWhen. // TODO: Test blocking to re-enter monitor after being signaled. // TODO: Test interrupts with both interruptible and uninterruptible monitor. // TODO: Test multiple waiters: If guard is still satisfied, signal next waiter.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 26 20:07:17 UTC 2023 - 7.9K bytes - Viewed (0) -
src/sync/cond_test.go
go func() { cond.Broadcast() }() go func() { m.Lock() for !done { cond.Wait() } m.Unlock() }() // Check that the first waiter does get signaled. <-ch // Release the second waiter in case it didn't get the // broadcast. m.Lock() done = true m.Unlock() cond.Broadcast() } } func TestCondCopy(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 22 18:52:42 UTC 2023 - 5K bytes - Viewed (0) -
src/runtime/signal_linux_s390x.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 17 20:42:23 UTC 2021 - 4.5K bytes - Viewed (0) -
pkg/util/goroutinemap/goroutinemap.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: Sat May 16 11:54:27 UTC 2020 - 6.8K bytes - Viewed (0) -
src/runtime/sys_linux_mips64x.s
MOVV $0(R29), R5 JMP fallback finish: MOVV 0(R29), R3 // sec MOVV 8(R29), R5 // nsec MOVV R16, R29 // restore SP // Restore vdsoPC, vdsoSP // We don't worry about being signaled between the two stores. // If we are not in a signal handler, we'll restore vdsoSP to 0, // and no one will care about vdsoPC. If we are in a signal handler, // we cannot receive another signal. MOVV 16(R29), R1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 18 20:57:24 UTC 2022 - 12K bytes - Viewed (0) -
src/syscall/syscall_js.go
var ForkLock sync.RWMutex type WaitStatus uint32 func (w WaitStatus) Exited() bool { return false } func (w WaitStatus) ExitStatus() int { return 0 } func (w WaitStatus) Signaled() bool { return false } func (w WaitStatus) Signal() Signal { return 0 } func (w WaitStatus) CoreDump() bool { return false } func (w WaitStatus) Stopped() bool { return false }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 6.7K bytes - Viewed (0) -
src/syscall/syscall_bsd.go
return -1 } return int(w >> shift) } func (w WaitStatus) Signaled() bool { return w&mask != stopped && w&mask != 0 } func (w WaitStatus) Signal() Signal { sig := Signal(w & mask) if sig == stopped || sig == 0 { return -1 } return sig } func (w WaitStatus) CoreDump() bool { return w.Signaled() && w&core != 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 07 10:34:48 UTC 2023 - 13.6K bytes - Viewed (0) -
src/net/pipe.go
} func makePipeDeadline() pipeDeadline { return pipeDeadline{cancel: make(chan struct{})} } // set sets the point in time when the deadline will time out. // A timeout event is signaled by closing the channel returned by waiter. // Once a timeout has occurred, the deadline can be refreshed by specifying a // t value in the future. // // A zero value for t prevents timeout.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.4K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
} try { while (!active.isEmpty()) { boolean signaled = condition.awaitUntil(expiry); if (!signaled) { failures.add(new RuntimeException("Timeout waiting for threads to finish.")); break; } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
w int // next position to write isFull bool err error block bool mu sync.Mutex wg sync.WaitGroup readCond *sync.Cond // Signaled when data has been read. writeCond *sync.Cond // Signaled when data has been written. } // New returns a new RingBuffer whose buffer has the given size. func New(size int) *RingBuffer { return &RingBuffer{ buf: make([]byte, size),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0)