From 1e57852eff7f516610e53c4ec05083a478e31b13 Mon Sep 17 00:00:00 2001 From: Deluan Date: Tue, 27 Oct 2020 20:12:27 -0400 Subject: [PATCH] Make pool's queue buffered. Workaround while we don't put the queue in disk --- core/pool/pool.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/core/pool/pool.go b/core/pool/pool.go index 6184fd79..885d8f6e 100644 --- a/core/pool/pool.go +++ b/core/pool/pool.go @@ -13,12 +13,15 @@ type Pool struct { //queue *dque.DQue } +// TODO This hardcoded value will go away when the queue is persisted in disk +const bufferSize = 10000 + func NewPool(name string, workerCount int, item interface{}, exec Executor) (*Pool, error) { p := &Pool{ name: name, item: item, exec: exec, - queue: make(chan work), + queue: make(chan work, bufferSize), end: make(chan bool), }