Changeset bdfc032 for libcfa/src/executor.cfa

Timestamp:

Feb 4, 2020, 11:35:26 AM (6 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

eef8dfb

Parents:

aefb247 (diff), 4f7b418 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge branch 'master' into dkobets-vector

File:

• libcfa/src/executor.cfa (modified) (2 diffs)

libcfa/src/executor.cfa

@@ -8 +8 @@
 #include <stdio.h>
 
-forall( otype T | is_node(T) | is_monitor(T) ) {
-    monitor Buffer {                                    // unbounded buffer
-        __queue_t( T ) queue;                           // unbounded list of work requests
-        condition delay;
-    }; // Buffer
-
+forall( dtype T )
+monitor Buffer {                                        // unbounded buffer
+    __queue_t( T ) queue;                               // unbounded list of work requests
+    condition delay;
+}; // Buffer
+forall( dtype T | is_node(T) ) {
     void insert( Buffer( T ) & mutex buf, T * elem ) with(buf) {
         append( queue, elem );                          // insert element into buffer
@@ -20 +20 @@
 
     T * remove( Buffer( T ) & mutex buf ) with(buf) {
-        if ( ! queue ) wait( delay );                   // no request to process ? => wait
-        return pop_head( queue );
+        if ( queue.head != 0 ) wait( delay );                   // no request to process ? => wait
+//      return pop_head( queue );
     } // remove
 } // distribution