Changeset 105fb21

Timestamp:

Nov 11, 2024, 10:29:15 PM (30 hours ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

master

Children:

41882628

Parents:

7e943e1

Message:

rename start_actor_system and stop_actor_system, add implicit messages start_msg and stop_msg

File:

• libcfa/src/concurrency/actor.hfa (modified) (6 diffs)

libcfa/src/concurrency/actor.hfa

@@ -398 +398 @@
 // TODO: update globals in this file to be static fields once the static fields project is done
 static executor * __actor_executor_ = 0p;
-static bool __actor_executor_passed = false;                    // was an executor passed to start_actor_system
+static bool __actor_executor_passed = false;                    // was an executor passed to actor_start
 static size_t __num_actors_ = 0;                                                // number of actor objects in system
 static struct thread$ * __actor_executor_thd = 0p;              // used to wake executor after actors finish
@@ -410 +410 @@
         // Once an actor is allocated it must be sent a message or the actor system cannot stop. Hence, its receive
         // member must be called to end it
-        DEBUG_ABORT( __actor_executor_ == 0p, "Creating actor before calling start_actor_system() can cause undefined behaviour.\n" );
+        DEBUG_ABORT( __actor_executor_ == 0p, "Creating actor before calling actor_start() can cause undefined behaviour.\n" );
         alloc = Nodelete;
         ticket = __get_next_ticket( *__actor_executor_ );
@@ -682 +682 @@
 }
 
-static inline void start_actor_system( size_t num_thds ) {
+static inline void actor_start( size_t num_thds ) {
         __reset_stats();
         __actor_executor_thd = active_thread();
@@ -689 +689 @@
 }
 
-static inline void start_actor_system() { start_actor_system( get_proc_count( *active_cluster() ) ); }
-
-static inline void start_actor_system( executor & this ) {
+static inline void actor_start() { actor_start( get_proc_count( *active_cluster() ) ); }
+
+static inline void actor_start( executor & this ) {
         __reset_stats();
         __actor_executor_thd = active_thread();
@@ -698 +698 @@
 }
 
-static inline void stop_actor_system() {
+static inline void actor_stop() {
         park();                                                                                         // unparked when actor system is finished
 
@@ -715 +715 @@
 struct finished_msg_t { inline message; } finished_msg = __base_msg_finished;
 
-allocation receive( actor & this, delete_msg_t & msg ) { return Delete; }
-allocation receive( actor & this, destroy_msg_t & msg ) { return Destroy; }
-allocation receive( actor & this, finished_msg_t & msg ) { return Finished; }
+allocation receive( actor & this, delete_msg_t & ) { return Delete; }
+allocation receive( actor & this, destroy_msg_t & ) { return Destroy; }
+allocation receive( actor & this, finished_msg_t & ) { return Finished; }
 
 // Default messages used all the time.
-//static struct startmsg_t { inline message; } start_msg; // start actor
-//static struct stopmsg_t { inline message; } stop_msg; // terminate actor
+struct start_msg_t { inline message; } start_msg = __base_msg_finished; // start actor
+struct stop_msg_t { inline message; } stop_msg = __base_msg_finished; // terminate actor