CAF 0.17.6
|
Policy-based implementation of the abstract worker base class. More...
#include <worker.hpp>
Public Types | |
using | job_ptr = resumable * |
using | coordinator_ptr = coordinator< Policy > * |
using | policy_data = typename Policy::worker_data |
Public Member Functions | |
worker (size_t worker_id, coordinator_ptr worker_parent, const policy_data &init, size_t throughput) | |
void | start () |
worker (const worker &)=delete | |
worker & | operator= (const worker &)=delete |
void | external_enqueue (job_ptr job) |
Enqueues a new job to the worker's queue from an external source, i.e., from any other thread. | |
void | exec_later (job_ptr job) override |
Enqueues a new job to the worker's queue from an internal source, i.e., a job that is currently executed by this worker. More... | |
coordinator_ptr | parent () |
size_t | id () const |
std::thread & | get_thread () |
actor_id | id_of (resumable *ptr) |
policy_data & | data () |
size_t | max_throughput () |
![]() | |
execution_unit (actor_system *sys) | |
execution_unit (execution_unit &&)=default | |
execution_unit & | operator= (execution_unit &&)=default |
execution_unit (const execution_unit &)=default | |
execution_unit & | operator= (const execution_unit &)=default |
virtual void | exec_later (resumable *ptr)=0 |
Enqueues ptr to the job list of the execution unit. More... | |
actor_system & | system () const |
Returns the enclosing actor system. More... | |
proxy_registry * | proxy_registry_ptr () |
Returns a pointer to the proxy factory currently associated to this unit. | |
void | proxy_registry_ptr (proxy_registry *ptr) |
Associated a new proxy factory to this unit. | |
Additional Inherited Members | |
![]() | |
actor_system * | system_ = nullptr |
proxy_registry * | proxies_ = nullptr |
Policy-based implementation of the abstract worker base class.
|
override |
Enqueues a new job to the worker's queue from an internal source, i.e., a job that is currently executed by this worker.