Index: libcfa/src/Exception.hfa
===================================================================
--- libcfa/src/Exception.hfa	(revision d923fca679790b81e32b6a12debf586d34a17e72)
+++ libcfa/src/Exception.hfa	(revision 98a5ee7757aa2f110b4759d6fd9b56048dd79e8e)
@@ -6,2 +6,3 @@
 #define ExceptionArgs( name, args... ) &name ## _vt, args
 #define ExceptionInst( name, args... ) (name){ ExceptionArgs( name, args ) }
+#define ExceptionPtr( E ) (exception_t *) & E
Index: libcfa/src/concurrency/future.hfa
===================================================================
--- libcfa/src/concurrency/future.hfa	(revision d923fca679790b81e32b6a12debf586d34a17e72)
+++ libcfa/src/concurrency/future.hfa	(revision 98a5ee7757aa2f110b4759d6fd9b56048dd79e8e)
@@ -9,7 +9,7 @@
 // Author           : Thierry Delisle & Peiran Hong & Colby Parsons
 // Created On       : Wed Jan 06 17:33:18 2021
-// Last Modified By : Kyoung Seo
-// Last Modified On : Mon Jan 27 20:35:00 2025
-// Update Count     : 3
+// Last Modified By : Peter A. Buhr
+// Last Modified On : Sun Mar  2 14:45:56 2025
+// Update Count     : 19
 //
 
@@ -26,79 +26,103 @@
 // future_t is lockfree and uses atomics which aren't needed given we use locks here
 forall( T ) {
-    enum { FUTURE_EMPTY = 0, FUTURE_FULFILLED = 1 };
+	enum { FUTURE_EMPTY = 0, FUTURE_FULFILLED = 1 };
 
 	struct future {
 		int state;
 		T result;
+		exception_t * except;
 		dlist( select_node ) waiters;
-        futex_mutex lock;
+		futex_mutex lock;
 	};
-    __CFA_SELECT_GET_TYPE( future(T) );
-
-    struct future_node {
-        inline select_node;
-        T * my_result;
-    };
+	__CFA_SELECT_GET_TYPE( future(T) );
+
+	struct future_node {
+		inline select_node;
+		T * my_result;
+	};
 
 	static inline {
 
-        void ?{}( future_node(T) & this, thread$ * blocked_thread, T * my_result ) {
-            ((select_node &)this){ blocked_thread };
-            this.my_result = my_result;
-        }
-
-        void ?{}( future(T) & this ) {
+		void ?{}( future_node(T) & this, thread$ * blocked_thread, T * my_result ) {
+			((select_node &)this){ blocked_thread };
+			this.my_result = my_result;
+		}
+
+		void ?{}( future(T) & this ) {
 			this.waiters{};
-            this.state = FUTURE_EMPTY;
-            this.lock{};
+			this.except = 0p;
+			this.state = FUTURE_EMPTY;
+			this.lock{};
+		}
+
+		void ^?{}( future(T) & this ) {
+			free( this.except );
 		}
 
 		// Reset future back to original state
-		void reset( future(T) & this ) with(this)
-        {
-            lock( lock );
-            if( ! waiters`isEmpty )
-                abort("Attempting to reset a future with blocked waiters");
-            state = FUTURE_EMPTY;
-            unlock( lock );
-        }
+		void reset( future(T) & this ) with(this) {
+			lock( lock );
+			if ( ! waiters`isEmpty )
+				abort("Attempting to reset a future with blocked waiters");
+			state = FUTURE_EMPTY;
+			free( except );
+			except = 0p;
+			unlock( lock );
+		}
 
 		// check if the future is available
-        // currently no mutual exclusion because I can't see when you need this call to be synchronous or protected
+		// currently no mutual exclusion because I can't see when you need this call to be synchronous or protected
 		bool available( future(T) & this ) { return __atomic_load_n( &this.state, __ATOMIC_RELAXED ); }
 
 
-        // memcpy wrapper to help copy values
-        void copy_T( T & from, T & to ) {
-            memcpy((void *)&to, (void *)&from, sizeof(T));
-        }
-
-        // internal helper to signal waiters off of the future
-        void _internal_flush( future(T) & this ) with(this) {
-            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 = try_pop_front( waiters );
-
-                if ( s.clause_status == 0p ) // poke in result so that woken threads do not need to reacquire any locks
-                    copy_T( result, *(((future_node(T) &)s).my_result) );
-
-                wake_one( waiters, s );
-            }
-        }
+		// memcpy wrapper to help copy values
+		void copy_T( T & from, T & to ) {
+			memcpy((void *)&to, (void *)&from, sizeof(T));
+		}
+
+		bool fulfil$( future(T) & this ) with(this) {	// helper
+			bool ret_val = ! waiters`isEmpty;
+			state = FUTURE_FULFILLED;
+			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 = try_pop_front( waiters );
+
+				if ( s.clause_status == 0p )			// poke in result so that woken threads do not need to reacquire any locks
+					copy_T( result, *(((future_node(T) &)s).my_result) );
+
+				wake_one( waiters, s );
+			}
+			unlock( lock );
+			return ret_val;
+		}
 
 		// Fulfil the future, returns whether or not someone was unblocked
 		bool fulfil( future(T) & this, T val ) with(this) {
-            lock( lock );
-            if( state != FUTURE_EMPTY )
-                abort("Attempting to fulfil a future that has already been fulfilled");
-
-            copy_T( val, result );
-
-            bool ret_val = ! waiters`isEmpty;
-            state = FUTURE_FULFILLED;
-			_internal_flush( this );
-            unlock( lock );
-            return ret_val;
+			lock( lock );
+			if ( state != FUTURE_EMPTY )
+				abort("Attempting to fulfil a future that has already been fulfilled");
+
+			copy_T( val, result );
+			return fulfil$( this );
+		}
+
+		bool ?()( future(T) & this, T val ) {			// alternate interface
+			return fulfil( this, val );
+		}
+
+		// Load an exception to the future, returns whether or not someone was unblocked
+		bool fulfil( future(T) & this, exception_t * ex ) with(this) {
+			lock( lock );
+			if ( state != FUTURE_EMPTY )
+				abort("Attempting to fulfil a future that has already been fulfilled");
+
+			except = ( exception_t * ) malloc( ex->virtual_table->size );
+			ex->virtual_table->copy( except, ex );
+			return fulfil$( this );
+		}
+
+		bool ?()( future(T) & this, exception_t * ex ) { // alternate interface
+			return fulfil( this, ex );
 		}
 
@@ -106,16 +130,27 @@
 		// Also return whether the thread had to block or not
 		[T, bool] get( future(T) & this ) with( this ) {
-            lock( lock );
-            T ret_val;
-            if( state == FUTURE_FULFILLED ) {
-                copy_T( result, ret_val );
-                unlock( lock );
-                return [ret_val, false];
-            }
-
-            future_node(T) node = { active_thread(), &ret_val };
-            insert_last( waiters, ((select_node &)node) );
-            unlock( lock );
-            park( );
+			void exceptCheck() {						// helper
+				if ( except ) {
+					exception_t * ex = ( exception_t * ) alloca( except->virtual_table->size );
+					except->virtual_table->copy( ex, except );
+					unlock( lock );
+					throwResume * ex;
+				}
+			}
+
+			lock( lock );
+			T ret_val;
+			if ( state == FUTURE_FULFILLED ) {
+				exceptCheck();
+				copy_T( result, ret_val );
+				unlock( lock );
+				return [ret_val, false];
+			}
+
+			future_node(T) node = { active_thread(), &ret_val };
+			insert_last( waiters, ((select_node &)node) );
+			unlock( lock );
+			park( );
+			exceptCheck();
 
 			return [ret_val, true];
@@ -129,52 +164,56 @@
 		}
 
-        // Gets value if it is available and returns [ val, true ]
-        // otherwise returns [ default_val, false]
-        // will not block
-        [T, bool] try_get( future(T) & this ) with(this) {
-            lock( lock );
-            T ret_val;
-            if( state == FUTURE_FULFILLED ) {
-                copy_T( result, ret_val );
-                unlock( lock );
-                return [ret_val, true];
-            }
-            unlock( lock );
-
-            return [ret_val, false];
-        }
-
-        bool register_select( future(T) & this, select_node & s ) with(this) {
-            lock( lock );
-
-            // check if we can complete operation. If so race to establish winner in special OR case
-            if ( !s.park_counter && state != FUTURE_EMPTY ) {
-                if ( !__make_select_node_available( s ) ) { // we didn't win the race so give up on registering
-                    unlock( lock );
-                    return false;
-                }
-            }
-
-            // future not ready -> insert select node and return
-            if( state == FUTURE_EMPTY ) {
-                insert_last( waiters, s );
-                unlock( lock );
-                return false;
-            }
-
-            __make_select_node_available( s );
-            unlock( lock );
-            return true;
-        }
-
-        bool unregister_select( future(T) & this, select_node & s ) with(this) {
-            if ( ! s`isListed ) return false;
-            lock( lock );
-            if ( s`isListed ) remove( s );
-            unlock( lock );
-            return false;
-        }
-
-        bool on_selected( future(T) &, select_node & ) { return true; }
+		T ?()( future(T) & this ) {						// alternate interface
+			return get( this );
+		}
+
+		// Gets value if it is available and returns [ val, true ]
+		// otherwise returns [ default_val, false]
+		// will not block
+		[T, bool] try_get( future(T) & this ) with(this) {
+			lock( lock );
+			T ret_val;
+			if ( state == FUTURE_FULFILLED ) {
+				copy_T( result, ret_val );
+				unlock( lock );
+				return [ret_val, true];
+			}
+			unlock( lock );
+
+			return [ret_val, false];
+		}
+
+		bool register_select( future(T) & this, select_node & s ) with(this) {
+			lock( lock );
+
+			// check if we can complete operation. If so race to establish winner in special OR case
+			if ( !s.park_counter && state != FUTURE_EMPTY ) {
+				if ( !__make_select_node_available( s ) ) { // we didn't win the race so give up on registering
+					unlock( lock );
+					return false;
+				}
+			}
+
+			// future not ready -> insert select node and return
+			if ( state == FUTURE_EMPTY ) {
+				insert_last( waiters, s );
+				unlock( lock );
+				return false;
+			}
+
+			__make_select_node_available( s );
+			unlock( lock );
+			return true;
+		}
+
+		bool unregister_select( future(T) & this, select_node & s ) with(this) {
+			if ( ! s`isListed ) return false;
+			lock( lock );
+			if ( s`isListed ) remove( s );
+			unlock( lock );
+			return false;
+		}
+
+		bool on_selected( future(T) &, select_node & ) { return true; }
 	}
 }
@@ -242,5 +281,5 @@
 
 		bool $first( multi_future(T) & mutex this ) {
-			if (this.has_first) {
+			if ( this.has_first ) {
 				wait( this.blocked );
 				return false;
@@ -258,6 +297,6 @@
 		// Reset future back to original state
 		void reset(multi_future(T) & mutex this) {
-			if( this.has_first != false) abort("Attempting to reset a multi_future with at least one blocked threads");
-			if( !is_empty(this.blocked) ) abort("Attempting to reset a multi_future with multiple blocked threads");
+			if ( this.has_first != false ) abort("Attempting to reset a multi_future with at least one blocked threads");
+			if ( !is_empty(this.blocked) ) abort("Attempting to reset a multi_future with multiple blocked threads");
 			reset( (future_t&)*(future_t*)((uintptr_t)&this + sizeof(monitor$)) );
 		}