Changes in libcfa/src/concurrency/future.hfa [6b33e89:3483185]

File:

• libcfa/src/concurrency/future.hfa (modified) (4 diffs)

libcfa/src/concurrency/future.hfa

@@ -10 +10 @@
 // Created On       : Wed Jan 06 17:33:18 2021
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Wed Apr 23 22:41:10 2025
-// Update Count     : 22
+// Last Modified On : Sun Mar  2 14:45:56 2025
+// Update Count     : 19
 //
 
@@ -63 +63 @@
                 void reset( future(T) & this ) with(this) {
                         lock( lock );
-                        if ( ! isEmpty( waiters ) )
+                        if ( ! waiters`isEmpty )
                                 abort("Attempting to reset a future with blocked waiters");
                         state = FUTURE_EMPTY;
@@ -82 +82 @@
 
                 bool fulfil$( future(T) & this ) with(this) {   // helper
-                        bool ret_val = ! isEmpty( waiters );
+                        bool ret_val = ! waiters`isEmpty;
                         state = FUTURE_FULFILLED;
-                        while ( ! isEmpty( waiters ) ) {
+                        while ( ! waiters`isEmpty ) {
                                 if ( !__handle_waituntil_OR( waiters ) ) // handle special waituntil OR case
                                         break; // if handle_OR returns false then waiters is empty so break
-                                select_node &s = remove_first( waiters );
+                                select_node &s = try_pop_front( waiters );
 
                                 if ( s.clause_status == 0p )                    // poke in result so that woken threads do not need to reacquire any locks
@@ -208 +208 @@
 
                 bool unregister_select( future(T) & this, select_node & s ) with(this) {
-                        if ( ! isListed( s ) ) return false;
-                        lock( lock );
-                        if ( isListed( s ) ) remove( s );
+                        if ( ! s`isListed ) return false;
+                        lock( lock );
+                        if ( s`isListed ) remove( s );
                         unlock( lock );
                         return false;