diff options
| author | kruall <[email protected]> | 2022-02-10 16:50:43 +0300 |
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:50:43 +0300 |
| commit | 08510f0e20c4cccf75a4a7577b1471638c521f08 (patch) | |
| tree | 9fd60922961d950d6761fcb0c694bcfca6594c9a /library/cpp/actors/util/threadparkpad.cpp | |
| parent | ce384ae51a2d2c465e4e0fe4fe0346e382459bfe (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.cpp | 16 |
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 |
