Changeset 0c78741 for src/libcfa/concurrency/monitor

Timestamp:

Apr 27, 2017, 2:00:07 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:

f80ab45

Parents:

e464759

Message:

Implementation of internal scheduling in CFA

File:

• src/libcfa/concurrency/monitor (modified) (1 diff)

src/libcfa/concurrency/monitor

@@ -46 +46 @@
 //-----------------------------------------------------------------------------
 // Internal scheduling
+
+struct __condition_criterion_t {
+        bool ready;                                             //Whether or not the criterion is met (True if met)
+        monitor_desc * target;                          //The monitor this criterion concerns
+        struct __condition_node_t * owner;              //The parent node to which this criterion belongs
+        __condition_criterion_t * next;         //Intrusive linked list Next field
+};
+
+struct __condition_node_t {
+        thread_desc * waiting_thread;                   //Thread that needs to be woken when all criteria are met
+        __condition_criterion_t * criteria;     //Array of criteria (Criterions are contiguous in memory)
+        unsigned short count;                           //Number of criterions in the criteria
+        __condition_node_t * next;                      //Intrusive linked list Next field
+};
+
+struct __condition_blocked_queue_t {
+        __condition_node_t * head;
+        __condition_node_t ** tail;
+};
+
+void ?{}( __condition_blocked_queue_t * );
+void append( __condition_blocked_queue_t *, __condition_node_t * );
+__condition_node_t * pop_head( __condition_blocked_queue_t * );
+
 struct condition {
-        __thread_queue_t blocked;
-        monitor_desc ** monitors;
-        unsigned short monitor_count;
+        __condition_blocked_queue_t blocked;    //Link list which contains the blocked threads as-well as the information needed to unblock them
+        monitor_desc ** monitors;                       //Array of monitor pointers (Monitors are NOT contiguous in memory)
+        unsigned short monitor_count;                   //Number of monitors in the array
 };