mirror of
https://github.com/fhmq/hmq.git
synced 2026-04-22 09:48:33 +00:00
rm a redundant creation of goroutines (#179)
Co-authored-by: husyhu <husyhu@qq.com>
This commit is contained in:
@@ -43,16 +43,14 @@ func (p *WorkerPool) dispatch() {
|
||||
}
|
||||
|
||||
func startWorker(taskChan chan func()) {
|
||||
go func() {
|
||||
var task func()
|
||||
var ok bool
|
||||
for {
|
||||
task, ok = <-taskChan
|
||||
if !ok {
|
||||
break
|
||||
}
|
||||
// Execute the task.
|
||||
task()
|
||||
var task func()
|
||||
var ok bool
|
||||
for {
|
||||
task, ok = <-taskChan
|
||||
if !ok {
|
||||
break
|
||||
}
|
||||
}()
|
||||
// Execute the task.
|
||||
task()
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user