concurrent

func Synchronized ¶

func Synchronized(mutex *sync.Mutex, operation func())

func SynchronizedWithCondition ¶

func SynchronizedWithCondition(mutex *sync.Mutex, cond *sync.Cond, operation func(cond *sync.Cond))

func WaitWithTimeout ¶

func WaitWithTimeout(cond *sync.Cond, timeout time.Duration) bool

CondWaitTimeout waits on condition until it is signaled or timeout elapses. It returns true if the timeout timer did NOT fire before we stopped it (i.e. wake was likely due to some other Signal/Broadcast), and false if the timeout timer has been fired.