Changes in libcfa/src/concurrency/locks.cfa [43784ac:82f4063]

File:

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

libcfa/src/concurrency/locks.cfa

@@ -16 +16 @@
 
 #define __cforall_thread__
-#define _GNU_SOURCE
 
 #include "locks.hfa"
@@ -28 +27 @@
 forall(L & | is_blocking_lock(L)) {
         struct info_thread {
-                // used to put info_thread on a dl queue (aka sequence)
-                inline Seqable;
+                // used to put info_thread on a dl queue
+                inline dlink(info_thread(L));
 
                 // waiting thread
@@ -43 +42 @@
                 bool signalled;
         };
+        P9_EMBEDDED( info_thread(L), dlink(info_thread(L)) )
 
         void ?{}( info_thread(L) & this, $thread * t, uintptr_t info, L * l ) {
-                ((Seqable &) this){};
                 this.t = t;
                 this.info = info;
@@ -52 +51 @@
 
         void ^?{}( info_thread(L) & this ) {}
-
-        info_thread(L) *& Back( info_thread(L) * this ) {
-                return (info_thread(L) *)Back( (Seqable *)this );
-        }
-
-        info_thread(L) *& Next( info_thread(L) * this ) {
-                return (info_thread(L) *)Next( (Colable *)this );
-        }
 }
 
@@ -86 +77 @@
         // lock is held by some other thread
         if ( owner != 0p && owner != thrd ) {
-                addTail( blocked_threads, *thrd );
+                insert_last( blocked_threads, *thrd );
                 wait_count++;
                 unlock( lock );
@@ -125 +116 @@
 
 void pop_and_set_new_owner( blocking_lock & this ) with( this ) {
-        $thread * t = &dropHead( blocked_threads );
+        $thread * t = &try_pop_front( blocked_threads );
         owner = t;
         recursion_count = ( t ? 1 : 0 );
@@ -154 +145 @@
         // lock held
         if ( owner != 0p ) {
-                addTail( blocked_threads, *t );
+                insert_last( blocked_threads, *t );
                 wait_count++;
                 unlock( lock );
@@ -207 +198 @@
                 //      may still be called after a thread has been removed from the queue but
                 //      before the alarm is unregistered
-                if ( listed(info_thd) ) {       // is thread on queue
+                if ( (*info_thd)`isListed ) {   // is thread on queue
                         info_thd->signalled = false;
                         // remove this thread O(1)
-                        remove( cond->blocked_threads, *info_thd );
+                        remove( *info_thd );
                         cond->count--;
                         if( info_thd->lock ) {
@@ -255 +246 @@
         bool notify_one( condition_variable(L) & this ) with( this ) {
                 lock( lock __cfaabi_dbg_ctx2 );
-                bool ret = !empty(blocked_threads);
-                process_popped(this, dropHead( blocked_threads ));
+                bool ret = ! blocked_threads`isEmpty;
+                process_popped(this, try_pop_front( blocked_threads ));
                 unlock( lock );
                 return ret;
@@ -263 +254 @@
         bool notify_all( condition_variable(L) & this ) with(this) {
                 lock( lock __cfaabi_dbg_ctx2 );
-                bool ret = !empty(blocked_threads);
-                while( !empty(blocked_threads) ) {
-                        process_popped(this, dropHead( blocked_threads ));
+                bool ret = ! blocked_threads`isEmpty;
+                while( ! blocked_threads`isEmpty ) {
+                        process_popped(this, try_pop_front( blocked_threads ));
                 }
                 unlock( lock );
@@ -272 +263 @@
 
         uintptr_t front( condition_variable(L) & this ) with(this) {
-                return empty(blocked_threads) ? NULL : head(blocked_threads).info;
+                return blocked_threads`isEmpty ? NULL : blocked_threads`first.info;
         }
 
         bool empty( condition_variable(L) & this ) with(this) {
                 lock( lock __cfaabi_dbg_ctx2 );
-                bool ret = empty(blocked_threads);
+                bool ret = blocked_threads`isEmpty;
                 unlock( lock );
                 return ret;
@@ -286 +277 @@
         size_t queue_and_get_recursion( condition_variable(L) & this, info_thread(L) * i ) with(this) {
                 // add info_thread to waiting queue
-                addTail( blocked_threads, *i );
+                insert_last( blocked_threads, *i );
                 count++;
                 size_t recursion_count = 0;