Changes in libcfa/src/concurrency/locks.cfa [dff1fd1:d25b2d6]

File:

• libcfa/src/concurrency/locks.cfa (modified) (8 diffs)

libcfa/src/concurrency/locks.cfa

@@ -17 +17 @@
                 this.t = t;
                 this.lock = 0p;
+                this.listed = false;
         }
 
@@ -24 +25 @@
                 this.info = info;
                 this.lock = 0p;
+                this.listed = false;
         }
 
@@ -34 +36 @@
         info_thread(L) *& Next( info_thread(L) * this ) {
                 return (info_thread(L) *)Next( (Colable *)this );
+        }
+
+        bool listed( info_thread(L) * this ) {
+                return Next( (Colable *)this ) != 0p;
         }
 }
@@ -188 +194 @@
         // This condition_variable member is called from the kernel, and therefore, cannot block, but it can spin.
             lock( cond->lock __cfaabi_dbg_ctx2 );
-            if ( listed(i) ) {                  // is thread on queue
-                i->signalled = false;
+            
+            if ( i->listed ) {                  // is thread on queue
                 cond->last_thread = i;          // REMOVE THIS AFTER DEBUG
                         remove( cond->blocked_threads, *i );             //remove this thread O(1)
@@ -221 +227 @@
         void process_popped( condition_variable(L) & this, info_thread(L) & popped ) with( this ) {
                 if(&popped != 0p) {
-                        popped.signalled = true;
+                        popped.listed = false;
                         count--;
                         if (popped.lock) {
@@ -260 +266 @@
                 addTail( blocked_threads, *i );
                 count++;
+                i->listed = true;
                 size_t recursion_count = 0;
                 if (i->lock) {
@@ -301 +308 @@
         }
         
-        bool wait( condition_variable(L) & this, Duration duration ) with(this) {
+        void wait( condition_variable(L) & this, Duration duration ) with(this) {
                 info_thread( L ) i = { active_thread() };
                 queue_info_thread_timeout(this, i, __kernel_get_time() + duration );
-                return i.signalled;
-        }
-
-        bool wait( condition_variable(L) & this, uintptr_t info, Duration duration ) with(this) { 
+        }
+
+        void wait( condition_variable(L) & this, uintptr_t info, Duration duration ) with(this) { 
                 info_thread( L ) i = { active_thread(), info };
                 queue_info_thread_timeout(this, i, __kernel_get_time() + duration );
-                return i.signalled;
-        }
-
-        bool wait( condition_variable(L) & this, Time time ) with(this) {
+        }
+
+        void wait( condition_variable(L) & this, Time time ) with(this) {
                 info_thread( L ) i = { active_thread() };
                 queue_info_thread_timeout(this, i, time);
-                return i.signalled;
-        }
-
-        bool wait( condition_variable(L) & this, uintptr_t info, Time time ) with(this) {
+        }
+
+        void wait( condition_variable(L) & this, uintptr_t info, Time time ) with(this) {
                 info_thread( L ) i = { active_thread(), info };
                 queue_info_thread_timeout(this, i, time);
-                return i.signalled;
         }
 
@@ -337 +340 @@
         }
         
-        bool wait( condition_variable(L) & this, L & l, Duration duration ) with(this) {
+        void wait( condition_variable(L) & this, L & l, Duration duration ) with(this) {
                 info_thread(L) i = { active_thread() };
                 i.lock = &l;
                 queue_info_thread_timeout(this, i, __kernel_get_time() + duration );
-                return i.signalled;
-        }
-        
-        bool wait( condition_variable(L) & this, L & l, uintptr_t info, Duration duration ) with(this) {
+        }
+        
+        void wait( condition_variable(L) & this, L & l, uintptr_t info, Duration duration ) with(this) {
                 info_thread(L) i = { active_thread(), info };
                 i.lock = &l;
                 queue_info_thread_timeout(this, i, __kernel_get_time() + duration );
-                return i.signalled;
-        }
-        
-        bool wait( condition_variable(L) & this, L & l, Time time ) with(this) {
+        }
+        
+        void wait( condition_variable(L) & this, L & l, Time time ) with(this) {
                 info_thread(L) i = { active_thread() };
                 i.lock = &l;
                 queue_info_thread_timeout(this, i, time );
-                return i.signalled;
-        }
-        
-        bool wait( condition_variable(L) & this, L & l, uintptr_t info, Time time ) with(this) {
+        }
+        
+        void wait( condition_variable(L) & this, L & l, uintptr_t info, Time time ) with(this) {
                 info_thread(L) i = { active_thread(), info };
                 i.lock = &l;
                 queue_info_thread_timeout(this, i, time );
-                return i.signalled;
-        }
-}
+        }
+}