haiwen/seafile-server
1
0
Fork 0
mirror of https://github.com/haiwen/seafile-server.git synced 2025-09-17 07:40:25 +00:00
Code Issues Releases Wiki Activity

Fix create closer error

Browse Source
This commit is contained in:
杨赫然
2023-07-25 11:17:50 +08:00
parent fdb51c1352
commit a19aacf198
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
fileserver/workerpool/workerpool.go
View File

@@ -25,6 +25,7 @@ func CreateWorkerPool(jobCB JobCB, n int) *WorkPool {
pool := new(WorkPool) pool := new(WorkPool)
pool.jobCB = jobCB pool.jobCB = jobCB
pool.jobs = make(chan Job, 100) pool.jobs = make(chan Job, 100)
pool.closer = z.NewCloser(n)
for i := 0; i < n; i++ { for i := 0; i < n; i++ {
go pool.run(pool.jobs) go pool.run(pool.jobs)
} }