Function NewTaskPool

controller/pool.go:21–23

(size int)

}

func NewTaskPool(size int) *TaskPool {
	return &TaskPool{make(chan *types.AlarmTask, size)}
}

// func (this *TaskPool) PutTasks(items map[string]cache.Item) error {
// 	if len(this.tasks) != 0 {