gxsync

type GenericTaskPool interface {
	// AddTask wait idle worker add task
	AddTask(t task) bool
	// AddTaskAlways add task to queues or do it immediately
	AddTaskAlways(t task)
	// AddTaskBalance add task to idle queue
	AddTaskBalance(t task)
	// Close use to close the task pool
	Close()
	// IsClosed use to check pool status.
	IsClosed() bool
}

type TaskPool struct {
	TaskPoolOptions
	// contains filtered or unexported fields
}

type TaskPoolOption func(*TaskPoolOptions)

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