concurrent

type BlockingQueue struct {
	Queue
	// contains filtered or unexported fields
}

type BurstWaitGroup struct {
	// contains filtered or unexported fields
}

type CarrierFuture interface {
	Payload() interface{}
}

type CompletableFuture interface {
	Complete(obj interface{})
	Cancel()
	Fail(err error)
	// contains filtered or unexported methods
}

type DefaultFuture struct {
	// contains filtered or unexported fields
}

type Future interface {
	Get() interface{}
	GetTimeout(timeout time.Duration) interface{}
	Done() <-chan struct{}
	Await() Future
	AwaitTimeout(timeout time.Duration) Future
	IsDone() bool
	IsSuccess() bool
	IsCancelled() bool
	IsError() bool
	Error() error
	Ctx() context.Context
	AddListener(listener FutureListener) Future
	Completable() CompletableFuture
	Immutable() ImmutableFuture
}

type FutureListener interface {
	Future
	OperationCompleted(f Future)
}

type ImmutableFuture interface {
	Get() interface{}
	GetTimeout(timeout time.Duration) interface{}
	Done() <-chan struct{}
	Await() Future
	AwaitTimeout(timeout time.Duration) Future
	IsDone() bool
	IsSuccess() bool
	IsCancelled() bool
	IsError() bool
	Error() error
	Ctx() context.Context
	AddListener(listener FutureListener) Future
}

type Queue struct {
	// contains filtered or unexported fields
}