- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 116 for waiters (1.26 sec)
-
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) -
pkg/kubelet/cloudresource/cloud_request_manager.go
// // * Readers of the result will wait on the monitor until the first result // has been saved. // * The sync loop (i.e. the only writer), will signal all waiters every // time it updates the result. nodeAddressesMonitor: sync.NewCond(&sync.Mutex{}), } } // NodeAddresses waits for the first sync loop to run. If no successful syncs // have run, it will return the most recent error. If node addresses have been
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 05 18:29:23 UTC 2021 - 4.5K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue.go
return } if request, f := p.pending[con]; f { p.pending[con] = request.CopyMerge(pushRequest) return } p.pending[con] = pushRequest p.queue = append(p.queue, con) // Signal waiters on Dequeue that a new item is available p.cond.Signal() } // Remove a proxy from the queue. If there are no proxies ready to be removed, this will block
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 16 01:37:15 UTC 2021 - 3.8K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/internal/filelock/filelock_fcntl.go
panic("unlock called on a file that is not locked") } err := setlkw(f.Fd(), syscall.F_UNLCK) mu.Lock() l := locks[ino] if len(l.queue) == 0 { // No waiters: remove the map entry. delete(locks, ino) } else { // The first waiter is sending us their file now. // Receive it and update the queue. l.owner = <-l.queue[0] l.queue = l.queue[1:] locks[ino] = l } delete(inodes, f)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 17 02:24:35 UTC 2023 - 5.5K bytes - Viewed (0) -
src/mime/quotedprintable/writer.go
import "io" const lineMaxLen = 76 // A Writer is a quoted-printable writer that implements [io.WriteCloser]. type Writer struct { // Binary mode treats the writer's input as pure binary and processes end of // line bytes as binary data. Binary bool w io.Writer i int line [78]byte cr bool } // NewWriter returns a new [Writer] that writes to w. func NewWriter(w io.Writer) *Writer {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 3.2K bytes - Viewed (0) -
src/internal/trace/raw/writer.go
// NewWriter creates a new byte format writer. func NewWriter(w io.Writer, v version.Version) (*Writer, error) { _, err := version.WriteHeader(w, v) return &Writer{w: w, v: v, specs: v.Specs()}, err } // WriteEvent writes a single event to the trace wire format stream. func (w *Writer) WriteEvent(e Event) error { // Check version. if e.Version != w.v {
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/compress/lzw/writer.go
// is a *[Writer]. func NewWriter(w io.Writer, order Order, litWidth int) io.WriteCloser { return newWriter(w, order, litWidth) } func newWriter(dst io.Writer, order Order, litWidth int) *Writer { w := new(Writer) w.init(dst, order, litWidth) return w } func (w *Writer) init(dst io.Writer, order Order, litWidth int) { switch order { case LSB:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:40 UTC 2024 - 7.9K bytes - Viewed (0) -
istioctl/pkg/writer/table/writer.go
"io" "strings" "unicode/utf8" "github.com/fatih/color" ) type ColoredTableWriter struct { writer io.Writer header Row rows []Row addRowFunc func(obj interface{}) Row } func NewStyleWriter(writer io.Writer) *ColoredTableWriter { return &ColoredTableWriter{ writer: writer, rows: make([]Row, 0), header: Row{}, } } type BuildRowFunc func(obj interface{}) Row
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Oct 08 04:41:42 UTC 2022 - 2.8K bytes - Viewed (0)