/
githubmirror
/
nbs
Обзор
Документация
Войти
/
githubmirror
/
nbs
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
library/cpp/yt/threading/notification_handle.h
49 строк
1 KB
babenko
YT-18571: Move HandleEintr and TNotificationHandle to library/cpp/yt
02 июн 2023, 22:55
02 июн 2023, 22:55
ec0b6c1
Код
Авторство
О чём код?
#pragma once #include "public.h" #include <util/system/platform.h> #ifdef _win_ #include <util/system/pipe.h> #endif namespace NYT::NThreading { //////////////////////////////////////////////////////////////////////////////// //! Provides a handle which can be used to wake up a polling thread. /*! * Internally implemented via |eventfd| API (for Linux) or pipes (for all other platforms). */ class TNotificationHandle { public: explicit TNotificationHandle(bool blocking = false); ~TNotificationHandle(); //! Called from an arbitrary thread to wake up the polling thread. //! Multiple wakeups are coalesced. void Raise(); //! Called from the polling thread to clear all outstanding notification. void Clear(); //! Returns the pollable handle, which becomes readable when #Raise is invoked. int GetFD() const; private: #ifdef _linux_ int EventFD_ = -1; #elif defined(_win_) TPipeHandle Reader_; TPipeHandle Writer_; #else int PipeFDs_[2] = {-1, -1}; #endif }; //////////////////////////////////////////////////////////////////////////////// } // namespace NYT::NThreading