After a carefully look, I found the wg in redisq.go is used only at RunQueue(), and has no Wait calls.
Should we add q.wg.Wait() to CloseTimeOut or some place else??
Because I'd really want to stop a running queue.
Please take this small quest into consideration. Thanks.. and thanks
After a carefully look, I found the wg in redisq.go is used only at RunQueue(), and has no Wait calls.
Should we add q.wg.Wait() to CloseTimeOut or some place else??
Because I'd really want to stop a running queue.
Please take this small quest into consideration. Thanks.. and thanks