async

type Future[T any] interface {

	// Map creates a new Future by applying a function to the successful result of this Future.
	Map(func(T) (T, error)) Future[T]

	// FlatMap creates a new Future by applying a function to the successful result of
	// this Future.
	FlatMap(func(T) (Future[T], error)) Future[T]

	// Join blocks until the Future is completed and returns either a result or an error.
	Join() (T, error)

	// Get blocks for at most the given time duration for this Future to complete
	// and returns either a result or an error.
	Get(time.Duration) (T, error)

	// Recover handles any error that this Future might contain using a resolver function.
	Recover(func() (T, error)) Future[T]

	// RecoverWith handles any error that this Future might contain using another Future.
	RecoverWith(Future[T]) Future[T]
	// contains filtered or unexported methods
}

type FutureImpl[T any] struct {
	// contains filtered or unexported fields
}

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

type Promise[T any] interface {

	// Success completes the underlying Future with a value.
	Success(T)

	// Failure fails the underlying Future with an error.
	Failure(error)

	// Future returns the underlying Future.
	Future() Future[T]
}

type PromiseImpl[T any] struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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

type Task[T any] struct {
	// contains filtered or unexported fields
}

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