enh(SocketReactor): Add start() method #4833 (#4835)

This commit is contained in:
Lara Dzivdzanovic 2025-01-08 15:48:58 +01:00 committed by Matej Kenda
parent d12d123cd4
commit 82751df9e5
2 changed files with 9 additions and 0 deletions

View File

@ -186,6 +186,9 @@ public:
/// until stop() is called (in a separate thread). /// until stop() is called (in a separate thread).
/// Can be overriden by inheriting classes. /// Can be overriden by inheriting classes.
void start();
/// Starts the SocketReactor.
void stop(); void stop();
/// Stops the SocketReactor. /// Stops the SocketReactor.
/// ///

View File

@ -157,6 +157,12 @@ void SocketReactor::sleep()
} }
void SocketReactor::start()
{
_stop.exchange(false);
}
void SocketReactor::stop() void SocketReactor::stop()
{ {
if (_stop.exchange(true)) return; if (_stop.exchange(true)) return;