diff options
Diffstat (limited to 'library/cpp/threading/equeue/equeue.h')
| -rw-r--r-- | library/cpp/threading/equeue/equeue.h | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/library/cpp/threading/equeue/equeue.h b/library/cpp/threading/equeue/equeue.h index c61b9f7b857..4d03ad051db 100644 --- a/library/cpp/threading/equeue/equeue.h +++ b/library/cpp/threading/equeue/equeue.h @@ -1,9 +1,10 @@ #pragma once #include <util/thread/pool.h> -#include <library/cpp/deprecated/atomic/atomic.h> #include <util/generic/ptr.h> +#include <atomic> + //actual queue limit will be (maxQueueSize - numBusyThreads) or 0 class TElasticQueue: public IThreadPool { public: @@ -23,6 +24,6 @@ private: private: THolder<IThreadPool> SlaveQueue_; size_t MaxQueueSize_ = 0; - TAtomic ObjectCount_ = 0; - TAtomic GuardCount_ = 0; + std::atomic<size_t> ObjectCount_ = 0; + std::atomic<size_t> GuardCount_ = 0; }; |
