Changes in src/libcfa/concurrency/invoke.h [ee897e4b:0157ca7]

File:

• src/libcfa/concurrency/invoke.h (modified) (4 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 signal_once {
-            volatile bool condition;
-            struct spinlock lock;
-            struct simple_thread_list blocked;
       };
 
@@ -50 +40 @@
             void append( struct simple_thread_list *, struct thread * );
             struct thread * pop_head( struct simple_thread_list * );
-
-            void ?{}(spinlock * this);
-            void ^?{}(spinlock * this);
-
-            void ?{}(signal_once * this);
-            void ^?{}(signal_once * this);
       }
       #endif
@@ -69 +53 @@
       };
 
-      enum coroutine_state { Halted, Start, Inactive, Active, Primed };
+      enum coroutine_state { Start, Inactive, Active, Halt, Primed };
 
       struct coroutine {
@@ -76 +60 @@
             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
+
             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;           // coroutine body used to store context
-            struct signal_once terminated;// indicate if execuation state is not halted
-            struct thread * next;         // instrusive link field for threads
+            struct coroutine c;
+            struct simple_lock lock;
+            struct thread * next;
       };