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

File:

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

libcfa/src/concurrency/locks.cfa

@@ -28 +28 @@
 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
-                struct $thread * t;
+                struct thread$ * t;
 
                 // shadow field
@@ -43 +43 @@
                 bool signalled;
         };
-
-        void ?{}( info_thread(L) & this, $thread * t, uintptr_t info, L * l ) {
-                ((Seqable &) this){};
+        P9_EMBEDDED( info_thread(L), dlink(info_thread(L)) )
+
+        void ?{}( info_thread(L) & this, thread$ * t, uintptr_t info, L * l ) {
                 this.t = t;
                 this.info = info;
@@ -52 +52 @@
 
         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 );
-        }
 }
 
@@ -79 +71 @@
 void lock( blocking_lock & this ) with( this ) {
         lock( lock __cfaabi_dbg_ctx2 );
-        $thread * thrd = active_thread();
+        thread$ * thrd = active_thread();
 
         // single acquisition lock is held by current thread
@@ -86 +78 @@
         // 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 +117 @@
 
 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 );
@@ -150 +142 @@
 }
 
-void on_notify( blocking_lock & this, $thread * t ) with( this ) {
+void on_notify( blocking_lock & this, thread$ * t ) with( this ) {
         lock( lock __cfaabi_dbg_ctx2 );
         // lock held
         if ( owner != 0p ) {
-                addTail( blocked_threads, *t );
+                insert_last( blocked_threads, *t );
                 wait_count++;
                 unlock( lock );
@@ -207 +199 @@
                 //      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 +247 @@
         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 +255 @@
         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 +264 @@
 
         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 +278 @@
         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;
@@ -374 +366 @@
 }
 
-$thread * V (semaphore & this, const bool doUnpark ) with( this ) {
-        $thread * thrd = 0p;
+thread$ * V (semaphore & this, const bool doUnpark ) with( this ) {
+        thread$ * thrd = 0p;
         lock( lock __cfaabi_dbg_ctx2 );
         count += 1;
@@ -392 +384 @@
 
 bool V(semaphore & this) with( this ) {
-        $thread * thrd = V(this, true);
+        thread$ * thrd = V(this, true);
         return thrd != 0p;
 }
 
 bool V(semaphore & this, unsigned diff) with( this ) {
-        $thread * thrd = 0p;
+        thread$ * thrd = 0p;
         lock( lock __cfaabi_dbg_ctx2 );
         int release = max(-count, (int)diff);