Merge pull request #66 from kayac/fix/response-queue-larger

extend response queue size x 100.
kayac · Oct 29, 2020 · 1e46722 · 1e46722
2 parents 5993f85 + 1449698
commit 1e46722
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/supervisor.go b/supervisor.go
@@ -192,7 +192,7 @@ func StartSupervisor(conf *config.Config) (Supervisor, error) {
 		worker := Worker{
 			id:    i,
 			queue: make(chan Request, wqSize),
-			respq: make(chan SenderResponse, wqSize),
+			respq: make(chan SenderResponse, wqSize*100),
 			wgrp:  &sync.WaitGroup{},
 			sn:    SenderNum,
 			ac:    ac,