syncutil

package

v1.3.8 Latest Latest Go to latest Published: Apr 3, 2024 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewSyncedQ() *SyncedQ

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

func (sq *SyncedQ) PopFront() any

Waits until a value is available

func (sq *SyncedQ) PushBack(v any)

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()

In case waitforset() is not going to be called.

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

Fails if not able to set while get() is ready.

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

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