executor

type Executor interface {
	Process(req Request) *sync.WaitGroup
	ProcessWithWaitGroup(r Request, wg *sync.WaitGroup)
}

type InlineableRequest interface {
	Request

	CanExecuteInline()
}

type Request interface {
	// The executor will call this method to serve the request.
	Execute()

	// The executor will call this method if the executor cannot serve the
	// request.  Cancel should be a cheap operation than Execute.
	Cancel()
}

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

type WorkPoolExecutorParams struct {
	// The number of worker in this pool.  Non-positive means unlimited.
	NumWorkers int

	// The amount of time a request can be in the queue before the request
	// gets cancelled.  If the value is non-positive, timeout is disabled.
	QueueTimeout time.Duration

	// How frequent should the work pool sweeps timed out requests from its
	// queue. CheckInterval must by positive when QueueTimeout is enabled.
	CheckInterval time.Duration
}