libcaf  0.15.3
Public Types | 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::actor_system::module
enum  id_t {
  scheduler,
  middleman,
  opencl_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.
 
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
 
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.
 

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

- Static Public Member Functions inherited from caf::scheduler::abstract_coordinator
static void cleanup_and_release (resumable *)
 
- Protected Attributes inherited from caf::scheduler::abstract_coordinator
std::atomic< size_t > next_worker_
 
size_t max_throughput_
 
size_t num_workers_
 
strong_actor_ptr timer_
 
strong_actor_ptr printer_
 
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: