- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 89 for waiters (0.59 sec)
-
src/runtime/testdata/testprognet/waiters.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 1.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go
s.mu.Unlock() } func (s *Weighted) notifyWaiters() { for { next := s.waiters.Front() if next == nil { break // No more waiters blocked. } w := next.Value.(waiter) if s.size-s.cur < w.n { // Not enough tokens for the next waiter. We could keep going (to try to // find a waiter with a smaller request), but under load that could cause
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 4.3K bytes - Viewed (0) -
src/sync/mutex.go
// the unlocking goroutine to the waiter at the front of the queue. // New arriving goroutines don't try to acquire the mutex even if it appears // to be unlocked, and don't try to spin. Instead they queue themselves at // the tail of the wait queue. // // If a waiter receives ownership of the mutex and sees that either // (1) it is the last waiter in the queue, or (2) it waited for less than 1 ms,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/eventclock/fake.go
// events to run at that or an earlier time. // Events should not advance the clock. But just in case they do... now := fec.Now() for len(fec.waiters) > 0 && !now.Before(fec.waiters[0].targetTime) { ew := heap.Pop(&fec.waiters).(eventWaiter) fec.clientWG.Add(1) go func(f eventclock.EventFunc, now time.Time) { f(now) fec.clientWG.Add(-1) }(ew.f, now) foundSome = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 7.9K bytes - Viewed (0) -
src/sync/cond_test.go
func TestCondSignalStealing(t *testing.T) { for iters := 0; iters < 1000; iters++ { var m Mutex cond := NewCond(&m) // Start a waiter. ch := make(chan struct{}) go func() { m.Lock() ch <- struct{}{} cond.Wait() m.Unlock() ch <- struct{}{} }() <-ch m.Lock() m.Unlock() // We know that the waiter is in the cond.Wait() call because we
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 22 18:52:42 UTC 2023 - 5K bytes - Viewed (0) -
src/sync/waitgroup.go
} // This goroutine has set counter to 0 when waiters > 0. // Now there can't be concurrent mutations of state: // - Adds must not happen concurrently with Wait, // - Wait does not increment waiters if it sees counter == 0. // Still do a cheap sanity check to detect WaitGroup misuse. if wg.state.Load() != state { panic("sync: WaitGroup misuse: Add called concurrently with Wait") } // Reset waiters count to 0. wg.state.Store(0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java
// TODO: Test interrupts with both interruptible and uninterruptible monitor. // TODO: Test multiple waiters: If guard is still satisfied, signal next waiter. // TODO: Test multiple waiters: If guard is no longer satisfied, do not 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) -
guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java
// TODO: Test interrupts with both interruptible and uninterruptible monitor. // TODO: Test multiple waiters: If guard is still satisfied, signal next waiter. // TODO: Test multiple waiters: If guard is no longer satisfied, do not signal next waiter.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 26 20:07:17 UTC 2023 - 8K bytes - Viewed (0) -
proguard/concurrent.pro
# Futures.getChecked, in both of its variants, is incompatible with proguard. # Used by AtomicReferenceFieldUpdater and sun.misc.Unsafe -keepclassmembers class com.google.common.util.concurrent.AbstractFuture** { *** waiters; *** value; *** listeners; *** thread; *** next; } -keepclassmembers class com.google.common.util.concurrent.AtomicDouble { *** value; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 09 00:29:01 UTC 2023 - 1.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress_test.go
return requestsSent == wantRequestsSent }); err != nil { t.Fatalf("Failed to wait progress requests, err: %s, want: %d , got %d", err, wantRequestsSent, requestsSent) } logger.Info("Adding waiters allows progress request to be sent") pr.Add() wantRequestsSent++ if err := pollConditionNoChange(pollPeriod, minimalNoChange, pollTimeout, func() bool { requestsSent = pr.progressRequestsSentCount.Load()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 4.6K bytes - Viewed (0)