|
Zth (libzth)
|
A single fiber per Worker that manages sleeping and blocked fibers. More...
#include <waiter.h>
Public Member Functions | |
| Waiter (Worker &worker) | |
| virtual | ~Waiter () override |
| void | wait (TimedWaitable &w) |
| void | scheduleTask (TimedWaitable &w) |
| void | unscheduleTask (TimedWaitable &w) |
| void | wakeup (TimedWaitable &w) |
| PollerServerBase & | poller () |
| void | setPoller (PollerServerBase *p=nullptr) |
| void | wakeup () |
Public Member Functions inherited from zth::Runnable | |
| virtual | ~Runnable ()=default |
| int | run () |
| Fiber * | fiber () const noexcept |
| operator Fiber & () const noexcept | |
| char const * | id_str () const |
Protected Member Functions | |
| bool | polling () const |
| virtual int | fiberHook (Fiber &f) override |
| virtual void | entry () override |
Protected Member Functions inherited from zth::Runnable | |
| constexpr | Runnable () noexcept |
| virtual void | cleanup () |
A single fiber per Worker that manages sleeping and blocked fibers.
|
explicit |
Definition at line 17 of file waiter.cpp.
|
overridevirtual |
Definition at line 23 of file waiter.cpp.
|
overrideprotectedvirtual |
Implements zth::Runnable.
Definition at line 151 of file waiter.cpp.
|
inlineoverrideprotectedvirtual |
Reimplemented from zth::Runnable.
| PollerServerBase & zth::Waiter::poller | ( | ) |
Definition at line 98 of file waiter.cpp.
|
protected |
Definition at line 109 of file waiter.cpp.
| void zth::Waiter::scheduleTask | ( | TimedWaitable & | w | ) |
Definition at line 62 of file waiter.cpp.
| void zth::Waiter::setPoller | ( | PollerServerBase * | p = nullptr | ) |
Definition at line 128 of file waiter.cpp.
| void zth::Waiter::unscheduleTask | ( | TimedWaitable & | w | ) |
Definition at line 74 of file waiter.cpp.
| void zth::Waiter::wait | ( | TimedWaitable & | w | ) |
Definition at line 34 of file waiter.cpp.
| void zth::Waiter::wakeup | ( | ) |
Definition at line 122 of file waiter.cpp.
| void zth::Waiter::wakeup | ( | TimedWaitable & | w | ) |
Definition at line 85 of file waiter.cpp.