Changeset f3da205 for libcfa/src/concurrency

Timestamp:

Jun 10, 2022, 2:59:53 PM (23 months ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

10ba012

Parents:

1c56bf7

Message:

Fixed wait_any to be polymorphic on future type.

Location:

libcfa/src/concurrency

Files:

• iofwd.hfa (modified) (1 diff)
• kernel/fwd.hfa (modified) (3 diffs)

libcfa/src/concurrency/iofwd.hfa

@@ -76 +76 @@
         void reset    ( io_future_t & this ) { return reset    (this.self); }
         bool available( io_future_t & this ) { return available(this.self); }
+        bool setup    ( io_future_t & this, oneshot & ctx ) { return setup  (this.self, ctx); }
+        bool retract  ( io_future_t & this, oneshot & ctx ) { return retract(this.self, ctx); }
 }
 

libcfa/src/concurrency/kernel/fwd.hfa

@@ -383 +383 @@
 
                         // Wait for any future to be fulfilled
-                        future_t & wait_any( future_t * futures, size_t num_futures ) {
+                        forall(T& | sized(T) | { bool setup( T&, oneshot & ); bool retract( T&, oneshot & ); })
+                        T & wait_any( T * futures, size_t num_futures ) {
                                 oneshot temp;
 
@@ -391 +392 @@
                                         if( !setup(futures[i], temp) ) return futures[i];
                                 }
-                                
+
                                 // Wait context is setup, just wait on it
                                 wait( temp );
-                                
+
                                 size_t ret;
                                 // attempt to retract all futures
@@ -400 +401 @@
                                         if ( retract( futures[i], temp ) ) ret = i;
                                 }
-                                
+
                                 return futures[ret];
                         }