Searched refs:wm (Results 1 – 3 of 3) sorted by relevance
57 wm *workerManager member86 func newWorker(wm *workerManager) *worker {88 wm: wm,102 w.wm.ReportResult(w, j, err)181 func (wm *workerManager) handleJobs() error {183 if len(wm.freeWorkers) == 0 {186 if wm.readyQueue.Len() == 0 {189 j := heap.Pop(&wm.readyQueue).(*job)193 w := wm.freeWorkers[0]194 wm.freeWorkers = wm.freeWorkers[1:][all …]
34 wm *workerManager member70 ex.wm.ReportNewDep(j, neededBy)113 return ex.wm.PostJob(j)141 wm, err := newWorkerManager(opt.NumJobs)149 wm: wm,195 n, err := ex.wm.Wait()
130 wm