go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-12-26 15:52:18 +08:00
Code Issues Projects Releases Wiki Activity

Fix: Use buffered channel of size 1 to avoid goroutine leaks

Browse Source
This commit is contained in:
Ken Hibino 2019-12-16 06:40:52 -08:00
parent 989b2b6d55
commit eb3216d354
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
processor.go
View File

@ -94,7 +94,7 @@ func (p *processor) exec() {
go func() { go func() {
defer func() { <-p.sema /* release token */ }() defer func() { <-p.sema /* release token */ }()
resCh := make(chan error) resCh := make(chan error, 1)
task := &Task{Type: msg.Type, Payload: msg.Payload} task := &Task{Type: msg.Type, Payload: msg.Payload}
go func() { go func() {
resCh <- perform(p.handler, task) resCh <- perform(p.handler, task)