summaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/equeue/equeue.h
diff options
context:
space:
mode:
Diffstat (limited to 'library/cpp/threading/equeue/equeue.h')
-rw-r--r--library/cpp/threading/equeue/equeue.h7
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;
};