Changeset db6f06a for src/libcfa/concurrency/invoke.h

Timestamp:

Feb 13, 2017, 5:04:43 PM (7 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, resolv-new, with_gc

Children:

ee897e4b

Parents:

75f3522

Message:

Implemented better condition lock to solve race condition on thread/processor termination

File:

• src/libcfa/concurrency/invoke.h (modified) (3 diffs)

src/libcfa/concurrency/invoke.h

@@ -30 +30 @@
       #define SCHEDULER_CAPACITY 10
 
+      struct spinlock {
+            volatile int lock;
+      };
+
       struct simple_thread_list {
             struct thread * head;
             struct thread ** tail;
+      };
+
+      // struct simple_lock {
+      //        struct simple_thread_list blocked;
+      // };
+
+      struct signal_once {
+            volatile bool condition;
+            struct spinlock lock;
+            struct simple_thread_list blocked;
       };
 
@@ -40 +54 @@
             void append( struct simple_thread_list *, struct thread * );
             struct thread * pop_head( struct simple_thread_list * );
+
+            // void ?{}(simple_lock * this);
+            // void ^?{}(simple_lock * this);
+
+            void ?{}(spinlock * this);
+            void ^?{}(spinlock * this);
+
+            void ?{}(signal_once * this);
+            void ^?{}(signal_once * this);
       }
       #endif
@@ -60 +83 @@
             int errno_;                         // copy of global UNIX variable errno
             enum coroutine_state state; // current execution status for coroutine
-            bool notHalted;                     // indicate if execuation state is not halted
-
+            bool notHalted;                   // indicate if execuation state is not halted
             struct coroutine *starter;  // first coroutine to resume this one
             struct coroutine *last;             // last coroutine to resume this one
       };
 
-      struct simple_lock {
-        struct simple_thread_list blocked;
-      };
-
       struct thread {
             struct coroutine c;
-            struct simple_lock lock;
+            signal_once terminated;             // indicate if execuation state is not halted
             struct thread * next;
       };