libcaf  0.15.5
Public Types | Public Member Functions | Static Public Member Functions | Protected Member Functions | List of all members
caf::scheduler::coordinator< Policy > Class Template Reference

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

#include <coordinator.hpp>

Inheritance diagram for caf::scheduler::coordinator< Policy >:
caf::scheduler::abstract_coordinator caf::actor_system::module caf::scheduler::profiled_coordinator< Policy >

Public Types

using super = abstract_coordinator
 
using policy_data = typename Policy::coordinator_data
 
using worker_type = worker< Policy >
 
- Public Types inherited from caf::scheduler::abstract_coordinator
enum  utility_actor_id : size_t {
  printer_id,
  timer_id,
  max_id
}
 
- Public Types inherited from caf::actor_system::module
enum  id_t {
  scheduler,
  middleman,
  opencl_manager,
  openssl_manager,
  num_ids
}
 

Public Member Functions

 coordinator (actor_system &sys)
 
worker_typeworker_by_id (size_t x)
 
policy_data & data ()
 
- Public Member Functions inherited from caf::scheduler::abstract_coordinator
 abstract_coordinator (actor_system &sys)
 
actor printer () const
 Returns a handle to the central printing actor.
 
actor timer () const
 Returns a handle to the central timer actor.
 
size_t num_utility_actors () const
 Returns the number of utility actors.
 
template<class Duration , class... Data>
void delayed_send (Duration rel_time, strong_actor_ptr from, strong_actor_ptr to, message_id mid, message data)
 
actor_systemsystem ()
 
size_t max_throughput () const
 
size_t num_workers () const
 
virtual bool detaches_utility_actors () const
 Returns true if this scheduler detaches its utility actors.
 
void init (actor_system_config &cfg) override
 Allows the module to change the configuration of the actor system during startup. More...
 
id_t id () const override
 Returns the identifier of this module.
 
void * subtype_ptr () override
 Returns a pointer to the subtype.
 

Static Public Member Functions

static actor_system::modulemake (actor_system &sys, detail::type_list<>)
 
- Static Public Member Functions inherited from caf::scheduler::abstract_coordinator
static void cleanup_and_release (resumable *)
 

Protected Member Functions

void start () override
 Starts any background threads needed by the module.
 
void stop () override
 Stops all background threads of the module.
 
void enqueue (resumable *ptr) override
 Puts what into the queue of a randomly chosen worker.
 
- Protected Member Functions inherited from caf::scheduler::abstract_coordinator
void stop_actors ()
 

Additional Inherited Members

- Protected Attributes inherited from caf::scheduler::abstract_coordinator
std::atomic< size_t > next_worker_
 
size_t max_throughput_
 
size_t num_workers_
 
std::array< actor, max_id > utility_actors_
 
actor_systemsystem_
 

Detailed Description

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

Policy-based implementation of the abstract coordinator base class.


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