func (f WorkerHandlerFunc) Handle(ctx context.Context, ev WorkerEvent) (interface{}, error) {
	return f(ctx, ev)
}
Handle implementation of WorkerHandler for WorkerHandlerFunc
package concurrent
import (
	"context"
	"sync/atomic"
	"time"
)
type Worker struct {
	lastEventTimestamp int64
	maxInactivity time.Duration
	key string
	handler WorkerHandler
	SharedC <-chan executeRequest
	C chan workerRequest
	ShutdownC chan error
	ErrC <-chan error
	doneC chan<- workerDestroyed
	UserData interface{}
}
type WorkerEvent interface {
	GetWorker() *Worker
}
type ErrorWorkerEvent struct {
	Worker *Worker
	Error  error
}
func (e ErrorWorkerEvent) GetWorker() *Worker {
	return e.Worker
}
type RequestWorkerEvent struct {
	Worker *Worker
	Value  interface{}
}
func (e RequestWorkerEvent) GetWorker() *Worker {
	return e.Worker
}
type WorkerHandler interface {
	Handle(ctx context.Context, req WorkerEvent) (interface{}, error)
}
type WorkerHandlerFunc func(ctx context.Context, ev WorkerEvent) (interface{}, error)