podman

1
//go:build !remote
2

3
package libpod
4

5
func (r *Runtime) startWorker() {
6
	r.workerChannel = make(chan func(), 10)
7
	go func() {
8
		for w := range r.workerChannel {
9
			w()
10
			r.workerGroup.Done()
11
		}
12
	}()
13
}
14

15
func (r *Runtime) queueWork(f func()) {
16
	r.workerGroup.Add(1)
17
	go func() {
18
		r.workerChannel <- f
19
	}()
20
}
21