Versions in this module Expand all Collapse all v1 v1.0.0 Apr 5, 2021 Changes in this version + var DummyTaskResult = struct{} + var InvalidTaskResult = &struct{} + type AtomicBool struct + func NewAtomicBool(n bool) AtomicBool + func (i *AtomicBool) CompareAndSwap(o, n bool) bool + func (i *AtomicBool) Get() bool + func (i *AtomicBool) Set(n bool) + type AtomicInt32 struct + func NewAtomicInt32(n int32) AtomicInt32 + func (i *AtomicInt32) Add(n int32) int32 + func (i *AtomicInt32) CompareAndSwap(oldVal, newVal int32) (swapped bool) + func (i *AtomicInt32) Get() int32 + func (i *AtomicInt32) Set(n int32) + type AtomicUint64 struct + func NewAtomicUint64(n uint64) AtomicUint64 + func (i *AtomicUint64) Add(n uint64) uint64 + func (i *AtomicUint64) CompareAndSwap(oldVal, newVal uint64) (swapped bool) + func (i *AtomicUint64) Get() uint64 + func (i *AtomicUint64) Set(n uint64) + type Set map[string]struct + func MakeSet(keys []string) Set + func (s *Set) Insert(key string) + func (s *Set) Reset() + func (s Set) Contains(key string) bool + func (s Set) InsertUnsafe(key string) + func (s Set) MustFirst() string + type Task struct + Data interface{} + ID TaskId + Name string + func NewTask(id TaskId, name string, runTimeout time.Duration, ...) *Task + func NewTaskNoResult(id TaskId, name string, runTimeout time.Duration, ...) *Task + func (t *Task) Cancel() + func (t *Task) Err() error + func (t *Task) ErrUnsafe() error + func (t *Task) Finished() bool + func (t *Task) Initialize(id TaskId, name string, runTimeout time.Duration, ...) *Task + func (t *Task) MustWaitFinishWithContext(ctx context.Context) + func (t *Task) OnFinished(g func()) + func (t *Task) Result() interface{} + func (t *Task) Run() error + func (t *Task) WaitFinish() + func (t *Task) WaitFinishWithContext(ctx context.Context) bool + type TaskId struct + Key string + TxnId uint64 + func NewTaskId(txnId uint64, key string) TaskId + func (id TaskId) Hash() uint64 + func (id TaskId) String() string