时间轮
This commit is contained in:
parent
e6ecb1e31d
commit
5903234295
@ -185,7 +185,10 @@ func (this *TimeWheel) handleTick() {
|
||||
}
|
||||
|
||||
if task.async {
|
||||
go this.calltask(task, task.args...)
|
||||
go func(task *Task) {
|
||||
go this.calltask(task, task.args...)
|
||||
}(task)
|
||||
|
||||
} else {
|
||||
// optimize gopool
|
||||
this.calltask(task, task.args...)
|
||||
|
Loading…
Reference in New Issue
Block a user