summaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/util/threadparkpad.cpp
diff options
context:
space:
mode:
authorkruall <[email protected]>2022-02-10 16:50:43 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:50:43 +0300
commit08510f0e20c4cccf75a4a7577b1471638c521f08 (patch)
tree9fd60922961d950d6761fcb0c694bcfca6594c9a /library/cpp/actors/util/threadparkpad.cpp
parentce384ae51a2d2c465e4e0fe4fe0346e382459bfe (diff)
Restoring authorship annotation for <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors/util/threadparkpad.cpp')
-rw-r--r--library/cpp/actors/util/threadparkpad.cpp16
1 files changed, 8 insertions, 8 deletions
diff --git a/library/cpp/actors/util/threadparkpad.cpp b/library/cpp/actors/util/threadparkpad.cpp
index 74069ff15bf..ece54844598 100644
--- a/library/cpp/actors/util/threadparkpad.cpp
+++ b/library/cpp/actors/util/threadparkpad.cpp
@@ -48,7 +48,7 @@ namespace NActors {
namespace NActors {
class TThreadParkPad::TImpl {
- TAtomic Interrupted;
+ TAtomic Interrupted;
HANDLE EvHandle;
public:
@@ -66,7 +66,7 @@ namespace NActors {
bool Park() noexcept {
::WaitForSingleObject(EvHandle, INFINITE);
- return AtomicGet(Interrupted);
+ return AtomicGet(Interrupted);
}
void Unpark() noexcept {
@@ -74,12 +74,12 @@ namespace NActors {
}
void Interrupt() noexcept {
- AtomicSet(Interrupted, true);
+ AtomicSet(Interrupted, true);
Unpark();
}
bool IsInterrupted() const noexcept {
- return AtomicGet(Interrupted);
+ return AtomicGet(Interrupted);
}
};
@@ -89,7 +89,7 @@ namespace NActors {
namespace NActors {
class TThreadParkPad::TImpl {
- TAtomic Interrupted;
+ TAtomic Interrupted;
TSystemEvent Ev;
public:
@@ -103,7 +103,7 @@ namespace NActors {
bool Park() noexcept {
Ev.Wait();
- return AtomicGet(Interrupted);
+ return AtomicGet(Interrupted);
}
void Unpark() noexcept {
@@ -111,12 +111,12 @@ namespace NActors {
}
void Interrupt() noexcept {
- AtomicSet(Interrupted, true);
+ AtomicSet(Interrupted, true);
Unpark();
}
bool IsInterrupted() const noexcept {
- return AtomicGet(Interrupted);
+ return AtomicGet(Interrupted);
}
};
#endif