Changeset 7f958c4 for libcfa/src/concurrency/locks.cfa

Timestamp:

May 4, 2022, 3:28:00 PM (2 years ago)

Author:

caparsons <caparson@…>

Branches:

ADT, ast-experimental, master, pthread-emulation, qualifiedEnum

Children:

ec57856

Parents:

f6737ae1

Message:

added fast lock/cond var

File:

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

libcfa/src/concurrency/locks.cfa

@@ -220 +220 @@
 
 //-----------------------------------------------------------------------------
-// condition variable
+// Synchronization Locks
 forall(L & | is_blocking_lock(L)) {
 
+        //-----------------------------------------------------------------------------
+        // condition variable
         void ?{}( condition_variable(L) & this ){
                 this.lock{};
@@ -337 +339 @@
         bool wait( condition_variable(L) & this, L & l, Duration duration                 ) with(this) { WAIT_TIME( 0   , &l , duration ) }
         bool wait( condition_variable(L) & this, L & l, uintptr_t info, Duration duration ) with(this) { WAIT_TIME( info, &l , duration ) }
+
+        //-----------------------------------------------------------------------------
+        // fast_cond_var
+        void  ?{}( fast_cond_var(L) & this ){
+                this.blocked_threads{}; 
+                #ifdef __CFA_DEBUG__
+                this.lock_used = 0p;
+                #endif
+        }
+        void ^?{}( fast_cond_var(L) & this ){ }
+
+        bool notify_one( fast_cond_var(L) & this ) with(this) {
+                bool ret = ! blocked_threads`isEmpty;
+                if ( ret ) {
+                        info_thread(L) & popped = try_pop_front( blocked_threads );
+                        on_notify(*popped.lock, popped.t);
+                }
+                return ret;
+        }
+        bool notify_all( fast_cond_var(L) & this ) with(this) {
+                bool ret = ! blocked_threads`isEmpty;
+                while( ! blocked_threads`isEmpty ) {
+                        info_thread(L) & popped = try_pop_front( blocked_threads );
+                        on_notify(*popped.lock, popped.t);
+                }
+                return ret;
+        }
+
+        uintptr_t front( fast_cond_var(L) & this ) with(this) { return blocked_threads`isEmpty ? NULL : blocked_threads`first.info; }
+        bool empty ( fast_cond_var(L) & this ) with(this) { return blocked_threads`isEmpty; }
+
+        void wait( fast_cond_var(L) & this, L & l ) {
+                wait( this, l, 0 );
+        }
+
+        void wait( fast_cond_var(L) & this, L & l, uintptr_t info ) with(this) {
+                // brand cond lock with lock
+                #ifdef __CFA_DEBUG__
+                        if ( lock_used == 0p ) lock_used = &l;
+                        else { assert(lock_used == &l); }
+                #endif
+                info_thread( L ) i = { active_thread(), info, &l };
+                insert_last( blocked_threads, i );
+                size_t recursion_count = on_wait( *i.lock );
+                park( );
+                on_wakeup(*i.lock, recursion_count);
+        }
 }