executor

type Executor interface {
	Completed() bool

	Wait() error
}

type Handler interface {
	RunAsync(ctx context.Context, f RunFunc) Executor

	Timeout(ctx context.Context, t Thread, f RunFunc, timeout, interval time.Duration) error

	WaitForSubThreads(t Thread)
}

type RunFunc func(ctx context.Context, log logging.Logger, t Thread, h Handler) error

type Thread interface {
	ID() ThreadID

	Release()
	Wait()
}

type ThreadID int

type ThreadManager interface {
	Acquire() Thread
}