Changeset a76efc8 for libcfa/src/concurrency

Timestamp:

Apr 24, 2021, 8:10:15 PM (3 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

c323837, fb0be05

Parents:

254ad1b

Message:

futures now optionally don't unpark the target thread

Location:

libcfa/src/concurrency

Files:

• io/types.hfa (modified) (1 diff)
• kernel/fwd.hfa (modified) (4 diffs)

libcfa/src/concurrency/io/types.hfa

@@ -179 +179 @@
 
 static inline {
-        bool fulfil( io_future_t & this, __s32 result ) {
+        $thread * fulfil( io_future_t & this, __s32 result, bool do_unpark = true ) {
                 this.result = result;
-                return fulfil(this.self);
+                return fulfil(this.self, do_unpark);
         }
 

libcfa/src/concurrency/kernel/fwd.hfa

@@ -219 +219 @@
                         // Mark as fulfilled, wake thread if needed
                         // return true if a thread was unparked
-                        bool post(oneshot & this) {
+                        $thread * post(oneshot & this, bool do_unpark = true) {
                                 struct $thread * got = __atomic_exchange_n( &this.ptr, 1p, __ATOMIC_SEQ_CST);
-                                if( got == 0p ) return false;
-                                unpark( got );
-                                return true;
+                                if( got == 0p ) return 0p;
+                                if(do_unpark) unpark( got );
+                                return got;
                         }
                 }
@@ -335 +335 @@
                         // from the server side, mark the future as fulfilled
                         // delete it if needed
-                        bool fulfil( future_t & this ) {
+                        $thread * fulfil( future_t & this, bool do_unpark = true  ) {
                                 for() {
                                         struct oneshot * expected = this.ptr;
@@ -343 +343 @@
                                                 #pragma GCC diagnostic ignored "-Wfree-nonheap-object"
                                         #endif
-                                                if( expected == 3p ) { free( &this ); return false; }
+                                                if( expected == 3p ) { free( &this ); return 0p; }
                                         #if defined(__GNUC__) && __GNUC__ >= 7
                                                 #pragma GCC diagnostic pop
@@ -355 +355 @@
                                         struct oneshot * want = expected == 0p ? 1p : 2p;
                                         if(__atomic_compare_exchange_n(&this.ptr, &expected, want, false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
-                                                if( expected == 0p ) { /* paranoid */ verify( this.ptr == 1p); return false; }
-                                                bool ret = post( *expected );
+                                                if( expected == 0p ) { /* paranoid */ verify( this.ptr == 1p); return 0p; }
+                                                $thread * ret = post( *expected, do_unpark );
                                                 __atomic_store_n( &this.ptr, 1p, __ATOMIC_SEQ_CST);
                                                 return ret;