Add start() method #4833

This commit is contained in:
Lara Dzivdzanovic 2025-01-02 17:56:02 +01:00
parent c9dc1f9d3c
commit 1bb4c1bd80
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;