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{}
	Await() Future
	IsDone() bool
	IsSuccess() bool
	IsCancelled() bool
	IsError() bool
	Error() error
	Ctx() context.Context
	AddListener(listener FutureListener) Future
}

type FutureListener interface {
	Future
	OperationCompleted(f Future)
}

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