wxiaoguang e159297443 Fix queue worker incorrectly stopped when there are still more items in the queue (#29532) ... Without `case <-t.C`, the workers would stop incorrectly, the test won't pass. For the worse case, there might be only one running worker processing the queue items for long time because other workers are stopped. The root cause is related to the logic of doDispatchBatchToWorker. It isn't a serious problem at the moment, so keep it as-is. (cherry picked from commit 6465f94a2d26cdacc232fddc20f98d98df61ddac)		2024-03-06 12:10:46 +08:00
..
lqinternal	Help to recover from corrupted levelqueue (#24912)	2023-05-29 10:52:32 +08:00
backoff.go	Rewrite queue (#24505)	2023-05-08 19:49:59 +08:00
base.go	Rewrite queue (#24505)	2023-05-08 19:49:59 +08:00
base_channel.go	Improve queue & process & stacktrace (#24636)	2023-05-11 07:45:47 +00:00
base_channel_test.go	Rewrite queue (#24505)	2023-05-08 19:49:59 +08:00
base_dummy.go	Rewrite queue (#24505)	2023-05-08 19:49:59 +08:00
base_levelqueue.go	Help to recover from corrupted levelqueue (#24912)	2023-05-29 10:52:32 +08:00
base_levelqueue_common.go	Help to recover from corrupted levelqueue (#24912)	2023-05-29 10:52:32 +08:00
base_levelqueue_test.go	Help to recover from corrupted levelqueue (#24912)	2023-05-29 10:52:32 +08:00
base_levelqueue_unique.go	Help to recover from corrupted levelqueue (#24912)	2023-05-29 10:52:32 +08:00
base_redis.go	Improve queue & process & stacktrace (#24636)	2023-05-11 07:45:47 +00:00
base_redis_test.go	[CI] disable redis test, no redis server yet in CI	2024-02-05 13:33:58 +01:00
base_test.go	Rewrite queue (#24505)	2023-05-08 19:49:59 +08:00
config.go	Rewrite queue (#24505)	2023-05-08 19:49:59 +08:00
manager.go	Improve queue and logger context (#24924)	2023-05-26 07:31:55 +00:00
manager_test.go	Increase queue length (#27555)	2023-10-10 18:47:49 +08:00
queue.go	Document the queue item's marshaling behavior (#27271)	2023-09-26 13:58:57 +08:00
testhelper.go	Rewrite queue (#24505)	2023-05-08 19:49:59 +08:00
workergroup.go	Fix queue worker incorrectly stopped when there are still more items in the queue (#29532)	2024-03-06 12:10:46 +08:00
workerqueue.go	Fix queue worker incorrectly stopped when there are still more items in the queue (#29532)	2024-03-06 12:10:46 +08:00
workerqueue_test.go	Fix queue worker incorrectly stopped when there are still more items in the queue (#29532)	2024-03-06 12:10:46 +08:00