Method Schedule

server/concurrency/goroutinepool.go:29–35

Schedule enqueus a closure to run on the GoRoutinePool's goroutines.

(task Task)

// Schedule enqueus a closure to run on the GoRoutinePool's goroutines.
func (p *GoRoutinePool) Schedule(task Task) {
	select {
	case p.work <- task:
	case p.sem <- struct{}{}:
		go p.worker(task)
	}
}

// Stop sends a stop signal to all running goroutines.
func (p *GoRoutinePool) Stop() {