Index: libcfa/src/concurrency/invoke.h
===================================================================
--- libcfa/src/concurrency/invoke.h	(revision 7d9598d809dda423890eb3996cfe6e61bc3b543b)
+++ libcfa/src/concurrency/invoke.h	(revision 2dcd80a064f6154cf7aad118ffd2a53fa127cab5)
@@ -10,6 +10,6 @@
 // Created On       : Tue Jan 17 12:27:26 2016
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Sun Jan  9 19:06:45 2022
-// Update Count     : 48
+// Last Modified On : Tue Nov 29 20:42:21 2022
+// Update Count     : 56
 //
 
@@ -17,4 +17,5 @@
 #include "bits/defs.hfa"
 #include "bits/locks.hfa"
+#include "bits/random.hfa"
 #include "kernel/fwd.hfa"
 
@@ -222,5 +223,5 @@
 		struct processor * last_proc;
 
-		uint32_t random_state;							// fast random numbers
+		PRNG_STATE_T random_state;						// fast random numbers
 
 		#if defined( __CFA_WITH_VERIFY__ )
Index: libcfa/src/concurrency/kernel.cfa
===================================================================
--- libcfa/src/concurrency/kernel.cfa	(revision 7d9598d809dda423890eb3996cfe6e61bc3b543b)
+++ libcfa/src/concurrency/kernel.cfa	(revision 2dcd80a064f6154cf7aad118ffd2a53fa127cab5)
@@ -10,6 +10,6 @@
 // Created On       : Tue Jan 17 12:27:26 2017
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Mon Aug 31 07:08:20 2020
-// Update Count     : 71
+// Last Modified On : Wed Nov 30 18:14:08 2022
+// Update Count     : 76
 //
 
@@ -151,5 +151,5 @@
 	// Because of a bug, we couldn't initialized the seed on construction
 	// Do it here
-	__cfaabi_tls.rand_seed ^= rdtscl();
+	PRNG_SET_SEED( __cfaabi_tls.random_state, rdtscl() );
 	__cfaabi_tls.ready_rng.fwd_seed = 25214903917_l64u * (rdtscl() ^ (uintptr_t)&runner);
 	__tls_rand_advance_bck();
Index: libcfa/src/concurrency/kernel/fwd.hfa
===================================================================
--- libcfa/src/concurrency/kernel/fwd.hfa	(revision 7d9598d809dda423890eb3996cfe6e61bc3b543b)
+++ libcfa/src/concurrency/kernel/fwd.hfa	(revision 2dcd80a064f6154cf7aad118ffd2a53fa127cab5)
@@ -46,9 +46,6 @@
 			} preemption_state;
 
-			#if defined(__SIZEOF_INT128__)
-				__uint128_t rand_seed;
-			#else
-				uint64_t rand_seed;
-			#endif
+			PRNG_STATE_T random_state;
+
 			struct {
 				uint64_t fwd_seed;
@@ -57,5 +54,4 @@
 
 			struct __stats_t        * volatile this_stats;
-
 
 			#ifdef __CFA_WITH_VERIFY__
@@ -76,11 +72,12 @@
 		#define publicTLS_get( member ) ((typeof(__cfaabi_tls.member))__cfatls_get( __builtin_offsetof(KernelThreadData, member) ))
 
-		static inline uint64_t __tls_rand() {
-			return
-			#if defined(__SIZEOF_INT128__)
-				lehmer64( kernelTLS().rand_seed );
-			#else
-				xorshift_13_7_17( kernelTLS().rand_seed );
-			#endif
+		static inline
+			#ifdef __x86_64__							// 64-bit architecture
+			uint64_t
+			#else										// 32-bit architecture
+			uint32_t
+			#endif // __x86_64__
+		__tls_rand() {
+			return PRNG_NAME( kernelTLS().random_state );
 		}
 
@@ -120,5 +117,5 @@
 
 		// Yield: yield N times
-		static inline void yield( unsigned times ) {
+		static inline void yield( size_t times ) {
 			for( times ) {
 				yield();
Index: libcfa/src/concurrency/kernel/startup.cfa
===================================================================
--- libcfa/src/concurrency/kernel/startup.cfa	(revision 7d9598d809dda423890eb3996cfe6e61bc3b543b)
+++ libcfa/src/concurrency/kernel/startup.cfa	(revision 2dcd80a064f6154cf7aad118ffd2a53fa127cab5)
@@ -39,4 +39,5 @@
 #include "limits.hfa"
 #include "math.hfa"
+#include "bits/random.hfa"								// prng
 
 #define CFA_PROCESSOR_USE_MMAP 0
@@ -107,5 +108,6 @@
 extern void __wake_proc(processor *);
 extern int cfa_main_returned;							// from interpose.cfa
-uint32_t __global_random_prime = 4_294_967_291u, __global_random_mask = false;
+size_t __global_random_prime = 4_294_967_291u;
+bool __global_random_mask = false;
 
 //-----------------------------------------------------------------------------
@@ -133,14 +135,14 @@
 // Global state
 __thread struct KernelThreadData __cfaabi_tls __attribute__ ((tls_model ( "initial-exec" ))) @= {
-	NULL,												// cannot use 0p
-	NULL,
-	false,
-	{ 1, false, false },
-	0,
-	{ 0, 0 },
-	NULL,
+	.this_thread : NULL,								// cannot use 0p
+	.this_processor : NULL,
+	.sched_lock : false,
+	.preemption_state : { .disable_count : 1, .enabled : false, .in_progress : false },
+	// random_state uninitialized
+	.ready_rng : { .fwd_seed : 0, .bck_seed : 0 },
+	.this_stats : NULL,
 	#ifdef __CFA_WITH_VERIFY__
-		false,
-		0,
+		.in_sched_lock : false,
+		.sched_id : 0,
 	#endif
 };
@@ -513,7 +515,11 @@
 	rdy_link.next = 0p;
 	rdy_link.ts   = MAX;
+	user_link.next = 0p;
+	user_link.prev = 0p;
+	cltr_link.next = 0p;
+	cltr_link.prev = 0p;
 	preferred = ready_queue_new_preferred();
 	last_proc = 0p;
-	random_state = __global_random_mask ? __global_random_prime : __global_random_prime ^ rdtscl();
+	PRNG_SET_SEED( random_state,  __global_random_mask ? __global_random_prime : __global_random_prime ^ rdtscl() );
 	#if defined( __CFA_WITH_VERIFY__ )
 		executing = 0p;
Index: libcfa/src/concurrency/stats.cfa
===================================================================
--- libcfa/src/concurrency/stats.cfa	(revision 7d9598d809dda423890eb3996cfe6e61bc3b543b)
+++ libcfa/src/concurrency/stats.cfa	(revision 2dcd80a064f6154cf7aad118ffd2a53fa127cab5)
@@ -48,5 +48,7 @@
 			stats->io.submit.eagr       = 0;
 			stats->io.submit.nblk       = 0;
+			stats->io.submit.extr       = 0;
 			stats->io.flush.external    = 0;
+			stats->io.flush.signal      = 0;
 			stats->io.flush.dirty       = 0;
 			stats->io.flush.full        = 0;
@@ -120,5 +122,7 @@
 			tally_one( &cltr->io.submit.eagr      , &proc->io.submit.eagr       );
 			tally_one( &cltr->io.submit.nblk      , &proc->io.submit.nblk       );
+			tally_one( &cltr->io.submit.extr      , &proc->io.submit.extr       );
 			tally_one( &cltr->io.flush.external   , &proc->io.flush.external    );
+			tally_one( &cltr->io.flush.signal     , &proc->io.flush.signal      );
 			tally_one( &cltr->io.flush.dirty      , &proc->io.flush.dirty       );
 			tally_one( &cltr->io.flush.full       , &proc->io.flush.full        );
@@ -199,5 +203,5 @@
 				if(io.alloc.slow) {
 					double avgfasts = (100.0 * (double)io.submit.fast) / total_submits;
-					sstr | "fast," | eng3(io.submit.slow) | "slow (" | ws(3, 3, avgfasts) | "%)" | nonl;
+					sstr | "fast," | eng3(io.submit.slow) | "slow (" | ws(3, 3, avgfasts) | "%)," | eng3(io.submit.extr) | "external" | nonl;
 				}
 				sstr | " - eager" | eng3(io.submit.eagr) | nonl;
@@ -217,5 +221,5 @@
 				     | " - cmp " | eng3(io.calls.locked) | "locked, " | eng3(io.calls.helped) | "helped"
 				     | " - " | eng3(io.calls.errors.busy) | " EBUSY";
-				sstr | " - sub: " | eng3(io.flush.full) | "full, " | eng3(io.flush.dirty) | "drty, " | eng3(io.flush.idle) | "idle, " | eng3(io.flush.eager) | "eagr, " | eng3(io.flush.external) | "ext";
+				sstr | " - sub: " | eng3(io.flush.full) | "full, " | eng3(io.flush.dirty) | "drty, " | eng3(io.flush.idle) | "idle, " | eng3(io.flush.eager) | "eagr, " | eng3(io.flush.external) | '/' | eng3(io.flush.signal) | "ext";
 				sstr | "- ops blk: "
 				     |   " sk rd: " | eng3(io.ops.sockread)  | "epll: " | eng3(io.ops.epllread)
Index: libcfa/src/concurrency/stats.hfa
===================================================================
--- libcfa/src/concurrency/stats.hfa	(revision 7d9598d809dda423890eb3996cfe6e61bc3b543b)
+++ libcfa/src/concurrency/stats.hfa	(revision 2dcd80a064f6154cf7aad118ffd2a53fa127cab5)
@@ -94,7 +94,9 @@
 				volatile uint64_t eagr;
 				volatile uint64_t nblk;
+				volatile uint64_t extr;
 			} submit;
 			struct {
 				volatile uint64_t external;
+				volatile uint64_t signal;
 				volatile uint64_t dirty;
 				volatile uint64_t full;
Index: libcfa/src/concurrency/thread.cfa
===================================================================
--- libcfa/src/concurrency/thread.cfa	(revision 7d9598d809dda423890eb3996cfe6e61bc3b543b)
+++ libcfa/src/concurrency/thread.cfa	(revision 2dcd80a064f6154cf7aad118ffd2a53fa127cab5)
@@ -10,6 +10,6 @@
 // Created On       : Tue Jan 17 12:27:26 2017
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Sat Feb 12 15:24:18 2022
-// Update Count     : 66
+// Last Modified On : Sun Dec 11 20:56:54 2022
+// Update Count     : 102
 //
 
@@ -26,5 +26,7 @@
 #include "invoke.h"
 
-extern uint32_t __global_random_seed, __global_random_prime, __global_random_mask;
+extern size_t __global_random_seed;
+extern size_t __global_random_prime;
+extern bool __global_random_mask;
 
 #pragma GCC visibility push(default)
@@ -46,7 +48,11 @@
 	rdy_link.next = 0p;
 	rdy_link.ts   = MAX;
+	user_link.next = 0p;
+	user_link.prev = 0p;
+	cltr_link.next = 0p;
+	cltr_link.prev = 0p;
 	preferred = ready_queue_new_preferred();
 	last_proc = 0p;
-	random_state = __global_random_mask ? __global_random_prime : __global_random_prime ^ rdtscl();
+	PRNG_SET_SEED( random_state, __global_random_mask ? __global_random_prime : __global_random_prime ^ rdtscl() );
 	#if defined( __CFA_WITH_VERIFY__ )
 		executing = 0p;
@@ -176,10 +182,7 @@
 //-----------------------------------------------------------------------------
 bool migrate( thread$ * thrd, struct cluster & cl ) {
-
 	monitor$ * tmon = get_monitor(thrd);
 	monitor$ * __monitors[] = { tmon };
 	monitor_guard_t __guard = { __monitors, 1 };
-
-
 	{
 		// if nothing needs to be done, return false
@@ -221,17 +224,15 @@
 
 //-----------------------------------------------------------------------------
-#define GENERATOR LCG
-
-void set_seed( uint32_t seed ) {
-	uint32_t & state = active_thread()->random_state;
-	state = __global_random_seed = seed;
-	GENERATOR( state );
-	__global_random_prime = state;
+
+void set_seed( size_t seed ) {
+	PRNG_STATE_T & state = active_thread()->random_state;
+	PRNG_SET_SEED( state, seed );
+	__global_random_seed = seed;
+	__global_random_prime = seed;
 	__global_random_mask = true;
 } // set_seed
 
-uint32_t prng( void ) {									// [0,UINT_MAX]
-	uint32_t & state = active_thread()->random_state;
-	return GENERATOR( state );
+size_t prng( void ) {									// [0,UINT_MAX]
+	return PRNG_NAME( active_thread()->random_state );
 } // prng
 
Index: libcfa/src/concurrency/thread.hfa
===================================================================
--- libcfa/src/concurrency/thread.hfa	(revision 7d9598d809dda423890eb3996cfe6e61bc3b543b)
+++ libcfa/src/concurrency/thread.hfa	(revision 2dcd80a064f6154cf7aad118ffd2a53fa127cab5)
@@ -10,6 +10,6 @@
 // Created On       : Tue Jan 17 12:27:26 2017
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Fri Feb 11 16:34:07 2022
-// Update Count     : 20
+// Last Modified On : Tue Nov 22 22:18:34 2022
+// Update Count     : 35
 //
 
@@ -23,4 +23,5 @@
 #include "monitor.hfa"
 #include "exception.hfa"
+#include "bits/random.hfa"
 
 //-----------------------------------------------------------------------------
@@ -141,12 +142,13 @@
 //----------
 // prng
+void set_seed( size_t seed );
 static inline {
-	uint32_t prng( thread$ & th ) __attribute__(( warn_unused_result )) { return LCG( th.random_state ); } // [0,UINT_MAX]
-	uint32_t prng( thread$ & th, uint32_t u ) __attribute__(( warn_unused_result )) { return prng( th ) % u; } // [0,u)
-	uint32_t prng( thread$ & th, uint32_t l, uint32_t u ) __attribute__(( warn_unused_result )) { return prng( th, u - l + 1 ) + l; } // [l,u]
+	size_t prng( thread$ & th ) __attribute__(( warn_unused_result )) { return PRNG_NAME( th.random_state ); } // [0,UINT_MAX]
+	size_t prng( thread$ & th, size_t u ) __attribute__(( warn_unused_result )) { return prng( th ) % u; } // [0,u)
+	size_t prng( thread$ & th, size_t l, size_t u ) __attribute__(( warn_unused_result )) { return prng( th, u - l + 1 ) + l; } // [l,u]
 	forall( T & | is_thread(T) ) {
-		uint32_t prng( T & th ) __attribute__(( warn_unused_result )) { return prng( (thread &)th ); } // [0,UINT_MAX]
-		uint32_t prng( T & th, uint32_t u ) __attribute__(( warn_unused_result )) { return prng( th ) % u; } // [0,u)
-		uint32_t prng( T & th, uint32_t l, uint32_t u ) __attribute__(( warn_unused_result )) { return prng( th, u - l + 1 ) + l; } // [l,u]
+	 	size_t prng( T & th ) __attribute__(( warn_unused_result )) { return prng( (thread &)th ); } // [0,UINT_MAX]
+		size_t prng( T & th, size_t u ) __attribute__(( warn_unused_result )) { return prng( th ) % u; } // [0,u)
+		size_t prng( T & th, size_t l, size_t u ) __attribute__(( warn_unused_result )) { return prng( th, u - l + 1 ) + l; } // [l,u]
 	} // distribution
 } // distribution