Merge branch '10.0'

2025-05-10 09:05:41 +00:00 · 2023-07-25 12:05:28 +08:00 · 2023-07-25 12:05:28 +08:00 · 2de172f6cc
commit 2de172f6cc
parent 910c338592 a19aacf198
1 changed files with 1 additions and 0 deletions
--- 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)
 	}