syncutil

type SyncedQ ¶

type SyncedQ struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSyncedQ() *SyncedQ

func (sq *SyncedQ) PeekFront() (any, bool)

func (sq *SyncedQ) PopFront() any

func (sq *SyncedQ) PushBack(v any)

type ThrottledTrigger ¶ added in v1.3.13

type ThrottledTrigger struct {
	// contains filtered or unexported fields
}

ThrottledTrigger calls a function after a period of inactivity (idle), or unconditionally once the max duration is reached — whichever comes first. Typical use: coalescing rapid updates (e.g. terminal redraws) into a single call, avoiding intermediate frames.

func NewThrottledTrigger(fn func(), idle, max time.Duration) *ThrottledTrigger

Each new Trigger() resets this window. Use a small value (e.g. 2ms)
to coalesce bursts of updates into a single paint.

being called continuously. Prevents starvation during sustained
output (e.g. cat largefile). Use ~16ms for ~60fps.

func (t *ThrottledTrigger) Trigger()

type Throttler ¶ added in v1.3.13

type Throttler struct {
	sync.Mutex

	Interval time.Duration
	Fn       func(done func())
	// contains filtered or unexported fields
}

runs fn only one at a time without overlaps, and always runs one last time.

func NewThrottler() *Throttler

func (thr *Throttler) Call()

type WaitForSet ¶

type WaitForSet struct {
	// contains filtered or unexported fields
}

Continously usable, instantiated once for many wait()/set() calls. Fails if wait() is not ready when set() is called. Usage:

w:=NewWaitForSet()
w.Start(5*time.Second)
...
// sync/async call to w.Set()
...
v,err := w.WaitForSet()
if err!=nil {
}

func NewWaitForSet() *WaitForSet

func (w *WaitForSet) Cancel()

func (w *WaitForSet) Set(v any) error

func (w *WaitForSet) Start(timeout time.Duration)

func (w *WaitForSet) WaitForSet() (any, error)