sync

Mar 18, 2024

Changes in this version

+ var ErrStopped = errors.New("ThreadGroup already stopped")

+ type ThreadGroup struct

+ func (tg *ThreadGroup) Add() error

+ func (tg *ThreadGroup) AfterStop(fn func())

+ func (tg *ThreadGroup) Done()

+ func (tg *ThreadGroup) Flush() error

+ func (tg *ThreadGroup) OnStop(fn func())

+ func (tg *ThreadGroup) Stop() error

+ func (tg *ThreadGroup) StopChan() <-chan struct{}

+ func (tg *ThreadGroup) StopCtx() context.Context

+ type TryMutex struct

+ func (tm *TryMutex) Lock()

+ func (tm *TryMutex) TryLock() bool

+ func (tm *TryMutex) TryLockTimed(t time.Duration) bool

+ func (tm *TryMutex) Unlock()