From a19aacf1987b3e5c31ee4f8c2cbb08db9f22a8d9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=A8=E8=B5=AB=E7=84=B6?= Date: Tue, 25 Jul 2023 11:17:50 +0800 Subject: [PATCH] Fix create closer error --- fileserver/workerpool/workerpool.go | 1 + 1 file changed, 1 insertion(+) diff --git a/fileserver/workerpool/workerpool.go b/fileserver/workerpool/workerpool.go index 9133cb3..40984c9 100644 --- a/fileserver/workerpool/workerpool.go +++ b/fileserver/workerpool/workerpool.go @@ -25,6 +25,7 @@ func CreateWorkerPool(jobCB JobCB, n int) *WorkPool { pool := new(WorkPool) pool.jobCB = jobCB pool.jobs = make(chan Job, 100) + pool.closer = z.NewCloser(n) for i := 0; i < n; i++ { go pool.run(pool.jobs) }