Policy-based implementation of the abstract worker base class. More...

#include <worker.hpp>

Inheritance diagram for caf::scheduler::worker< Policy >:

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.
coordinator_ptr	parent ()
size_t	id () const
std::thread &	get_thread ()
actor_id	id_of (resumable *ptr)
policy_data &	data ()
size_t	max_throughput ()
Public Member Functions inherited from caf::execution_unit
	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.
actor_system &	system () const
	Returns the enclosing actor system.
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
Protected Attributes inherited from caf::execution_unit
actor_system *	system_ = nullptr
proxy_registry *	proxies_ = nullptr

Detailed Description

template<class Policy>
class caf::scheduler::worker< Policy >

Policy-based implementation of the abstract worker base class.

Member Function Documentation

template<class Policy>

void caf::scheduler::worker< Policy >::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.

The documentation for this class was generated from the following file:

/build/actor-framework-Z9pIPl/actor-framework-0.17.6/libcaf_core/caf/scheduler/worker.hpp