parallelisation

Jul 18, 2023

Changes in this version

+ func SafeSchedule(ctx context.Context, period time.Duration, offset time.Duration, ...)

+ func SafeScheduleAfter(ctx context.Context, offset time.Duration, f func(context.Context, time.Time))

Sep 10, 2021

Changes in this version

+ func ScheduleAfter(ctx context.Context, offset time.Duration, f func(time.Time))

Aug 25, 2021

Changes in this version

+ func DetermineContextError(ctx context.Context) error

+ func Parallelise(argList interface{}, action func(arg interface{}) (interface{}, error), ...) (results interface{}, err error)

+ func RunActionWithParallelCheck(ctx context.Context, action func(ctx context.Context) error, ...) error

+ func RunActionWithTimeout(blockingAction func(stop chan bool) error, timeout time.Duration) (err error)

+ func RunActionWithTimeoutAndCancelStore(ctx context.Context, timeout time.Duration, store *CancelFunctionStore, ...) error

+ func RunActionWithTimeoutAndContext(ctx context.Context, timeout time.Duration, ...) error

+ func Schedule(ctx context.Context, period time.Duration, offset time.Duration, ...)

+ func SleepWithContext(ctx context.Context, delay time.Duration)

+ func SleepWithInterruption(stop chan bool, delay time.Duration)

+ type CancelFunctionStore struct

+ func NewCancelFunctionsStore() *CancelFunctionStore

+ func (s *CancelFunctionStore) Cancel()

+ func (s *CancelFunctionStore) Len() int

+ func (s *CancelFunctionStore) RegisterCancelFunction(cancel ...context.CancelFunc)