concurrency

type ExecutionFn func(ctx context.Context, args interface{}) (interface{}, error)

type Result struct {
	Value      interface{}
	Err        error
	Descriptor TaskDescriptor
}

type Task struct {
	Args       interface{}
	ExecFn     ExecutionFn
	Descriptor TaskDescriptor
}

type TaskDescriptor struct {
	Metadata TaskMetadata
	TaskType TaskType
	ID       TaskID
}

type TaskID uint32

type TaskMetadata map[string]interface{}

type TaskType string

type WorkerPool struct {
	Tasks                    chan Task   // input tasks to work parallel following order
	Results                  chan Result // output result channel, results will be in order as per input task order
	WorkerPoolName           string
	WorkerStopChannel        []chan bool   // worker stop channel
	WorkerInputReadyChannel  []chan bool   // worker input ready channel
	WorkerOutputReadyChannel []chan bool   // worker output ready channel
	LoopTimeOut              time.Duration // read loop timeout limit, default 2 seconds
	WorkersCount             int
	TasksCount               int
}