MCPcopy Create free account
hub / github.com/HyBuildNet/quic-relay / Start

Method Start

internal/proxy/pool.go:62–67  ·  view source on GitHub ↗

Start launches all worker goroutines.

()

Source from the content-addressed store, hash-verified

60
61// Start launches all worker goroutines.
62func (p *WorkerPool) Start() {
63 for i := 0; i < p.workers; i++ {
64 p.wg.Add(1)
65 go p.worker(i)
66 }
67}
68
69// Stop gracefully shuts down the pool and waits for workers to finish.
70func (p *WorkerPool) Stop() {

Callers 6

TestWorkerPool_SubmitFunction · 0.95
TestWorkerPool_StopFunction · 0.95
TestWorkerPool_QueueSizeFunction · 0.95
RunMethod · 0.80

Calls 1

workerMethod · 0.95

Tested by 5

TestWorkerPool_SubmitFunction · 0.76
TestWorkerPool_StopFunction · 0.76
TestWorkerPool_QueueSizeFunction · 0.76