plebble
|
#include <bgtask.h>
Public Types | |
typedef bgtask | b |
Public Member Functions | |
wbgtask (function< void()> onwakeup) | |
virtual | ~wbgtask () |
virtual void | collect ()=0 |
virtual void | task_init () |
virtual void | task ()=0 |
virtual void | task_cleanup () |
![]() | |
bgtask () | |
bgtask (function< void()> run, function< void()> onwakeup) | |
virtual | ~bgtask () |
void | set_run_function (function< void()> r) |
virtual ko | start () |
virtual ko | wait_ready (const chrono::system_clock::time_point &deadline) const |
virtual void | stop () |
virtual void | join () |
void | wakeup () |
bool | isup () const |
bool | isdown () const |
bool | resumed () const |
void | run_ () |
void | reset () |
bool | reset_wait () |
bool | reset_resume () |
bool | is_active () const |
bgtask () | |
bgtask (callback cb0) | |
void | set_callback (callback r) |
ko | start () |
ko | wait_ready (Date deadline) |
void | stop () |
void | join () |
boolean | reset_wait () |
void | wakeup () |
boolean | reset_resume () |
boolean | isup () |
boolean | isdown () |
boolean | resumed () |
void | reset () |
boolean | is_active () |
Private Member Functions | |
void | collect_ () |
void | run () |
Additional Inherited Members | |
![]() | |
static const char * | KO_81021 |
static ko | KO_81021 =new ko("KO 81021 Ready status never reached.") |
![]() | |
atomic< short > | resume {0} |
thread * | th {nullptr} |
bool | active {false} |
function< void()> | run |
function< void()> | onwakeup |
mutex | mx_ready |
bool | ready {false} |
condition_variable | cv_ready |
AtomicInteger | resume =new AtomicInteger(0) |
Thread | th =null |
boolean | active =false |
callback | cb =null |
ReentrantLock | mx_ready = new ReentrantLock() |
boolean | ready =false |
Condition | cv_ready =mx_ready.newCondition() |
typedef bgtask us::gov::wbgtask::b |
us::gov::wbgtask::wbgtask | ( | function< void()> | onwakeup | ) |
|
virtual |
|
pure virtual |
Implemented in us::gov::socket::gc_t.
|
private |
|
private |
Reimplemented from us::gov::bgtask.
|
pure virtual |
Implemented in us::gov::socket::gc_t.
|
inlinevirtual |
Reimplemented in us::gov::socket::gc_t.
|
inlinevirtual |
Reimplemented in us::gov::socket::gc_t.