From 475c0a46f28166e83fd263badc7546377cddcabe Mon Sep 17 00:00:00 2001
From: eeight <eeight@yandex-team.ru>
Date: Thu, 10 Feb 2022 16:46:18 +0300
Subject: Restoring authorship annotation for <eeight@yandex-team.ru>. Commit 1
 of 2.

---
 library/cpp/threading/equeue/equeue.cpp    | 4 ++--
 library/cpp/threading/equeue/equeue.h      | 6 +++---
 library/cpp/threading/equeue/equeue_ut.cpp | 6 +++---
 3 files changed, 8 insertions(+), 8 deletions(-)

(limited to 'library/cpp/threading/equeue')

diff --git a/library/cpp/threading/equeue/equeue.cpp b/library/cpp/threading/equeue/equeue.cpp
index 54a848e912a..4a708ef3ad9 100644
--- a/library/cpp/threading/equeue/equeue.cpp
+++ b/library/cpp/threading/equeue/equeue.cpp
@@ -71,10 +71,10 @@ void TElasticQueue::Start(size_t threadCount, size_t maxQueueSize) {
     SlaveQueue_->Start(threadCount, maxQueueSize);
 }
 
-void TElasticQueue::Stop() noexcept {
+void TElasticQueue::Stop() noexcept { 
     return SlaveQueue_->Stop();
 }
 
-size_t TElasticQueue::Size() const noexcept {
+size_t TElasticQueue::Size() const noexcept { 
     return SlaveQueue_->Size();
 }
diff --git a/library/cpp/threading/equeue/equeue.h b/library/cpp/threading/equeue/equeue.h
index 40dd342585e..ff735399e68 100644
--- a/library/cpp/threading/equeue/equeue.h
+++ b/library/cpp/threading/equeue/equeue.h
@@ -1,11 +1,11 @@
 #pragma once
 
-#include <util/thread/pool.h>
+#include <util/thread/pool.h> 
 #include <util/system/atomic.h>
 #include <util/generic/ptr.h>
 
 //actual queue limit will be (maxQueueSize - numBusyThreads) or 0
-class TElasticQueue: public IThreadPool {
+class TElasticQueue: public IThreadPool { 
 public:
     explicit TElasticQueue(THolder<IThreadPool> slaveQueue);
 
@@ -21,7 +21,7 @@ private:
 
     bool TryIncCounter();
 private:
-    THolder<IThreadPool> SlaveQueue_;
+    THolder<IThreadPool> SlaveQueue_; 
     size_t MaxQueueSize_ = 0;
     TAtomic ObjectCount_ = 0;
     TAtomic GuardCount_ = 0;
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) {
-- 
cgit v1.3