concurrent

Jan 16, 2022

Changes in this version

type DefaultFuture

+ func (f *DefaultFuture) Set(obj interface{})

+ type Settable interface

+ Set func(obj interface{})

Jan 16, 2022

Changes in this version

+ type ChainFuture interface

+ Parent func() ChainFuture

+ func NewChainFuture(future ChainFuture) ChainFuture

+ type Completable interface

+ Cancel func() bool

+ Complete func(obj interface{}) bool

+ Fail func(err error) bool

type DefaultFuture

+ func (f *DefaultFuture) Chainable() ChainFuture

+ func (f *DefaultFuture) GetNow() interface{}

+ func (f *DefaultFuture) IsFail() bool

+ func (f *DefaultFuture) Parent() ChainFuture

+ func (f *DefaultFuture) Then(fn func(parent Future) interface{}) (future Future)

+ func (f *DefaultFuture) ThenAsync(fn func(parent Future) interface{}) (future Future)

type Future

+ func Do(f func() interface{}) (future Future)

+ func DoAsync(f func() interface{}) (future Future)

+ func NewCompletedFuture(obj interface{}) Future

+ Chainable func() ChainFuture

+ Then func(fn func(parent Future) interface{}) (future Future)

+ ThenAsync func(fn func(parent Future) interface{}) (future Future)

+ type Immutable interface

+ AddListener func(listener FutureListener) Future

+ Await func() Future

+ AwaitTimeout func(timeout time.Duration) Future

+ Done func() <-chan struct{}

+ Error func() error

+ Get func() interface{}

+ GetNow func() interface{}

+ GetTimeout func(timeout time.Duration) interface{}

+ IsCancelled func() bool

+ IsDone func() bool

+ IsFail func() bool

+ IsSuccess func() bool

type Mutex

+ func (m *Mutex) IsLocked() bool

+ func (m *Mutex) Unlocked() chan struct{}

+ type TryLocker interface

+ TryLock func() bool

+ TryLockTimeout func(timeout time.Duration) bool

Nov 25, 2021

Changes in this version

+ type Mutex struct

+ func (m *Mutex) Lock()

+ func (m *Mutex) TryLock() bool

+ func (m *Mutex) TryLockTimeout(timeout time.Duration) bool

+ func (m *Mutex) Unlock()

Nov 19, 2021

Changes in this version

type DefaultFuture

+ func (f *DefaultFuture) Immutable() ImmutableFuture

type Future

+ Immutable func() ImmutableFuture

+ type ImmutableFuture interface

+ AddListener func(listener FutureListener) Future

+ Await func() Future

+ AwaitTimeout func(timeout time.Duration) Future

+ Ctx func() context.Context

+ Done func() <-chan struct{}

+ Error func() error

+ Get func() interface{}

+ GetTimeout func(timeout time.Duration) interface{}

+ IsCancelled func() bool

+ IsDone func() bool

+ IsError func() bool

+ IsSuccess func() bool

Nov 17, 2021

Changes in this version

type DefaultFuture

+ func (f *DefaultFuture) AwaitTimeout(timeout time.Duration) Future

+ func (f *DefaultFuture) GetTimeout(timeout time.Duration) interface{}

type Future

+ AwaitTimeout func(timeout time.Duration) Future

+ GetTimeout func(timeout time.Duration) interface{}

Sep 17, 2021

Changes in this version

type DefaultFuture

+ func (f *DefaultFuture) Done() <-chan struct{}

type Future

+ Done func() <-chan struct{}

Sep 6, 2021

Changes in this version

type DefaultFuture

+ func (f *DefaultFuture) Completable() CompletableFuture

type Future

+ Completable func() CompletableFuture

Aug 31, 2021

Changes in this version

+ type BlockingQueue struct

+ func (q *BlockingQueue) Pop() interface{}

+ func (q *BlockingQueue) Push(obj interface{}) *BlockingQueue

+ func (q *BlockingQueue) Reset() *BlockingQueue

+ type BurstWaitGroup struct

+ func (w *BurstWaitGroup) Add(delta int)

+ func (w *BurstWaitGroup) Burst()

+ func (w *BurstWaitGroup) Done()

+ func (w *BurstWaitGroup) Remain() int

+ func (w *BurstWaitGroup) Wait()

+ type CarrierFuture interface

+ Payload func() interface{}

+ type CompletableFuture interface

+ Cancel func()

+ Complete func(obj interface{})

+ Fail func(err error)

+ type DefaultFuture struct

+ func (f *DefaultFuture) AddListener(listener FutureListener) Future

+ func (f *DefaultFuture) Await() Future

+ func (f *DefaultFuture) Cancel()

+ func (f *DefaultFuture) Complete(obj interface{})

+ func (f *DefaultFuture) Ctx() context.Context

+ func (f *DefaultFuture) Error() error

+ func (f *DefaultFuture) Fail(err error)

+ func (f *DefaultFuture) Get() interface{}

+ func (f *DefaultFuture) IsCancelled() bool

+ func (f *DefaultFuture) IsDone() bool

+ func (f *DefaultFuture) IsError() bool

+ func (f *DefaultFuture) IsSuccess() bool

+ func (f *DefaultFuture) Payload() interface{}

+ type Future interface

+ AddListener func(listener FutureListener) Future

+ Await func() Future

+ Ctx func() context.Context

+ Error func() error

+ Get func() interface{}

+ IsCancelled func() bool

+ IsDone func() bool

+ IsError func() bool

+ IsSuccess func() bool

+ func NewCancelledFuture() Future

+ func NewCarrierFuture(obj interface{}) Future

+ func NewFailedFuture(err error) Future

+ func NewFuture(ctx context.Context) Future

+ func NewSucceededFuture(obj interface{}) Future

+ type FutureListener interface

+ OperationCompleted func(f Future)

+ func NewFutureListener(f func(f Future)) FutureListener

+ type Queue struct

+ func (q *Queue) Len() int

+ func (q *Queue) Pop() interface{}

+ func (q *Queue) Push(obj interface{}) *Queue

+ func (q *Queue) Reset() *Queue