summaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/equeue/equeue_ut.cpp
diff options
context:
space:
mode:
authoreeight <[email protected]>2022-02-10 16:46:18 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:46:18 +0300
commit475c0a46f28166e83fd263badc7546377cddcabe (patch)
tree39c5a49b8aaad78fe390b6f1f2886bdbda40f3e7 /library/cpp/threading/equeue/equeue_ut.cpp
parenta6e0145a095c7bb3770d6e07aee301de5c73f96e (diff)
Restoring authorship annotation for <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/threading/equeue/equeue_ut.cpp')
-rw-r--r--library/cpp/threading/equeue/equeue_ut.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/library/cpp/threading/equeue/equeue_ut.cpp b/library/cpp/threading/equeue/equeue_ut.cpp
index 9cf2aced44e..d08a94848b3 100644
--- a/library/cpp/threading/equeue/equeue_ut.cpp
+++ b/library/cpp/threading/equeue/equeue_ut.cpp
@@ -95,7 +95,7 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) {
Counters.Reset();
TryCounter = 0;
- struct TSender: public IThreadFactory::IThreadAble {
+ struct TSender: public IThreadFactory::IThreadAble {
void DoExecute() override {
while ((size_t)AtomicIncrement(TryCounter) <= N) {
if (!TryAdd()) {
@@ -108,9 +108,9 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) {
{
TQueueSetup setup;
- TVector< TAutoPtr<IThreadFactory::IThread> > senders;
+ TVector< TAutoPtr<IThreadFactory::IThread> > senders;
for (size_t i = 0; i < ThreadCount; ++i) {
- senders.push_back(::SystemThreadFactory()->Run(&sender));
+ senders.push_back(::SystemThreadFactory()->Run(&sender));
}
for (size_t i = 0; i < senders.size(); ++i) {