collab/hmq
3
0
Fork 0
mirror of https://github.com/fhmq/hmq.git synced 2026-05-04 07:08:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

add config for work chan

Browse Source
This commit is contained in:
joy.zhou
2019-07-15 15:10:56 +08:00
parent f15d0db08a
commit 22f9764220
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pool/fixpool.go
View File

@@ -37,7 +37,7 @@ func (p *WorkerPool) Submit(uid string, task func()) {
func (p *WorkerPool) dispatch() { func (p *WorkerPool) dispatch() {
for i := 0; i < p.maxWorkers; i++ { for i := 0; i < p.maxWorkers; i++ {
p.taskQueue[i] = make(chan func()) p.taskQueue[i] = make(chan func(), 1024)
go startWorker(p.taskQueue[i]) go startWorker(p.taskQueue[i])
} }
} }