MCPcopy
hub / github.com/tinode/chat / worker

Method worker

server/concurrency/goroutinepool.go:46–56  ·  view source on GitHub ↗

Thread pool worker goroutine.

(task Task)

Source from the content-addressed store, hash-verified

44
45// Thread pool worker goroutine.
46func (p *GoRoutinePool) worker(task Task) {
47 defer func() { <-p.sem }()
48 for {
49 task()
50 select {
51 case task = <-p.work:
52 case <-p.stop:
53 return
54 }
55 }
56}

Callers 1

ScheduleMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected