Merge pull request #129 from ruudk/patch-1

StopAllProcesses in parallel
ochinchina · Feb 8, 2019 · ef69f1b · ef69f1b
2 parents 7bdcbab + b1a2eb2
commit ef69f1b
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/process/process_manager.go b/process/process_manager.go
@@ -175,9 +175,19 @@ func (pm *ProcessManager) getAllProcess() []*Process {
 }
 
 func (pm *ProcessManager) StopAllProcesses() {
+	var wg sync.WaitGroup
+
 	pm.ForEachProcess(func(proc *Process) {
-		proc.Stop(true)
+		wg.Add(1)
+
+		go func(wg *sync.WaitGroup) {
+			defer wg.Done()
+
+			proc.Stop(true)
+		}(&wg)
 	})
+
+	wg.Wait()
 }
 
 func sortProcess(procs []*Process) []*Process {