gconcurrent

type JobFunc func(context.Context)

type PanicFunc func(recovered interface{}, funcName string)

type TimeoutCond struct {
	L sync.Locker
	// contains filtered or unexported fields
}

type WorkerPool interface {
	// Execute add worker function to queue to wait for executing by worker goroutine
	Execute(f JobFunc)

	// Execute summit worker function to queue  with a timeout timer,
	// if add queue success it will wait for executing by worker goroutine
	Submit(f JobFunc, timeout time.Duration) error

	// Stop cancel all goroutines started by this pool and wait
	Shutdown(ctx context.Context)

	// Stats return the statistics of worker pool
	Stats() WpStats

	// Option return the configuration of worker pool
	Option() WpOption
}

type WpOption struct {
	InitWorkerNum int       `json:"init_worker_num" yaml:"init_worker_num"`
	MaxWorkerNum  int       `json:"max_worker_num" yaml:"max_worker_num"`
	QueueSize     int       `json:"queue_size" yaml:"queue_size"`
	PanicFunc     PanicFunc `json:"-"`
}

type WpStats struct {
	ActiveNum     int32
	WorkerNum     int32
	ExecuteNum    int32
	SubmitFailNum int32
	PanicNum      int32
}