From 3e306dfc87eef33670765d97b72a833628e04cba Mon Sep 17 00:00:00 2001 From: kulikov Date: Mon, 23 Mar 2026 17:14:35 +0300 Subject: Allow to change (reduce) max queue size for common elastic queue Add same method as in TFastElasticQueue, and test. commit_hash:0a2b618325e57c32fd269254a7dbe912849c3f10 --- library/cpp/threading/equeue/equeue_ut.cpp | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) (limited to 'library/cpp/threading/equeue/equeue_ut.cpp') diff --git a/library/cpp/threading/equeue/equeue_ut.cpp b/library/cpp/threading/equeue/equeue_ut.cpp index 0b66128c73d..615d3d877d5 100644 --- a/library/cpp/threading/equeue/equeue_ut.cpp +++ b/library/cpp/threading/equeue/equeue_ut.cpp @@ -88,6 +88,25 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) { UNIT_ASSERT_VALUES_EQUAL(0u, TEnv::Queue->ObjectCount()); UNIT_ASSERT_VALUES_EQUAL(0u, TEnv::Queue->Size()); UNIT_ASSERT_VALUES_EQUAL(Counters.Processed.load(), enqueued); + + Counters.Reset(); + + enqueued = 0; + { + TLocalSetup setup; + TEnv::Queue->SetCurrentMaxQueueSize(MaxQueueSize / 2); + + while (TEnv::Queue->Add(&job) && enqueued < MaxQueueSize + 100) { + ++enqueued; + } + + UNIT_ASSERT_VALUES_EQUAL(enqueued, MaxQueueSize / 2); + UNIT_ASSERT_VALUES_EQUAL(enqueued, TEnv::Queue->ObjectCount()); + } + + UNIT_ASSERT_VALUES_EQUAL(0u, TEnv::Queue->ObjectCount()); + UNIT_ASSERT_VALUES_EQUAL(0u, TEnv::Queue->Size()); + UNIT_ASSERT_VALUES_EQUAL(Counters.Processed.load(), enqueued); } Y_UNIT_TEST(FillTest) { -- cgit v1.3