Changes in libcfa/src/concurrency/locks.cfa [7f958c4:708ae38]

File:

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

libcfa/src/concurrency/locks.cfa

@@ -220 +220 @@
 
 //-----------------------------------------------------------------------------
-// Synchronization Locks
+// condition variable
 forall(L & | is_blocking_lock(L)) {
 
-        //-----------------------------------------------------------------------------
-        // condition variable
         void ?{}( condition_variable(L) & this ){
                 this.lock{};
@@ -339 +337 @@
         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);
-        }
 }