diff --git a/core/pool/pool.go b/core/pool/pool.go index 56d729e67..c94d546c2 100644 --- a/core/pool/pool.go +++ b/core/pool/pool.go @@ -67,6 +67,10 @@ func (p *Pool) Submit(workload interface{}) { p.queue <- work{workload} } +func (p *Pool) Stop() { + p.done <- true +} + type work struct { workload interface{} } @@ -84,8 +88,3 @@ func (w *worker) Start() { } }() } - -// end worker -func (p *Pool) Stop() { - p.done <- true -}