syncutil

Documentation

Index

• func WaitWithTimeout(wg *sync.WaitGroup, timeout time.Duration) bool
• type Signaler
  • func NewSignaler() *Signaler
  • func (s *Signaler) Signal()

Functions

func WaitWithTimeout

func WaitWithTimeout(wg *sync.WaitGroup, timeout time.Duration) bool

WaitWithTimeout waits for the waitgroup to finish for the given timeout. It returns true if the waitgroup finished before the timeout, false otherwise.

Types

type Signaler

type Signaler struct {
	C chan struct{}
	// contains filtered or unexported fields
}

Signaler allows for multiple writers to safely signal an event so that reader on the channel C would get unblocked

func NewSignaler

func NewSignaler() *Signaler

NewSignaler initializes a new obj

func (*Signaler) Signal

func (s *Signaler) Signal()

Signal safely closes the blocking channel