You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

wxiaoguang 6465f94a2d 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.		12 months ago
..
lqinternal	…
backoff.go	…
base.go	…
base_channel.go	…
base_channel_test.go	…
base_dummy.go	…
base_levelqueue.go	…
base_levelqueue_common.go	…
base_levelqueue_test.go	…
base_levelqueue_unique.go	…
base_redis.go	…
base_redis_test.go	…
base_test.go	…
config.go	…
manager.go	…
manager_test.go	Increase queue length (#27555)	1 year ago
queue.go	Document the queue item's marshaling behavior (#27271)	1 year ago
testhelper.go	…
workergroup.go	Fix queue worker incorrectly stopped when there are still more items in the queue (#29532)	12 months ago
workerqueue.go	Fix queue worker incorrectly stopped when there are still more items in the queue (#29532)	12 months ago
workerqueue_test.go	Fix queue worker incorrectly stopped when there are still more items in the queue (#29532)	12 months ago