Index: benchmark/readyQ/transfer.cfa
===================================================================
--- benchmark/readyQ/transfer.cfa	(revision 3613e25a2dfc24b60fe9f336c21f73c0b94b92f7)
+++ benchmark/readyQ/transfer.cfa	(revision 5c231c17eaf89139bc7b23f158a6e0f3468ef04d)
@@ -14,4 +14,6 @@
 
 bool exhaust = false;
+volatile bool estop = false;
+
 
 thread$ * the_main;
@@ -35,5 +37,5 @@
 static void waitgroup() {
 	Time start = timeHiRes();
-	for(i; nthreads) {
+	OUTER: for(i; nthreads) {
 		PRINT( sout | "Waiting for :" | i | "(" | threads[i]->idx | ")"; )
 		while( threads[i]->idx != lead_idx ) {
@@ -42,5 +44,7 @@
 				print_stats_now( bench_cluster, CFA_STATS_READY_Q | CFA_STATS_IO );
 				serr | "Programs has been blocked for more than 5 secs";
-				exit(1);
+				estop = true;
+				unpark( the_main );
+				break OUTER;
 			}
 		}
@@ -59,5 +63,5 @@
 static void lead(MyThread & this) {
 	this.idx = ++lead_idx;
-	if(lead_idx > stop_count) {
+	if(lead_idx > stop_count || estop) {
 		PRINT( sout | "Leader" | this.id | "done"; )
 		unpark( the_main );
@@ -100,5 +104,5 @@
 			wait( this );
 		}
-		if(lead_idx > stop_count) break;
+		if(lead_idx > stop_count || estop) break;
 	}
 }
@@ -172,7 +176,8 @@
 	sout | "Number of processors    : " | nprocs;
 	sout | "Number of threads       : " | nthreads;
-	sout | "Total Operations(ops)   : " | stop_count;
+	sout | "Total Operations(ops)   : " | lead_idx - 1;
 	sout | "Threads parking on wait : " | (exhaust ? "yes" : "no");
 	sout | "Rechecking              : " | rechecks;
+	sout | "ns per transfer         : " | (end - start)`dms / lead_idx;
 
 
Index: benchmark/readyQ/transfer.cpp
===================================================================
--- benchmark/readyQ/transfer.cpp	(revision 3613e25a2dfc24b60fe9f336c21f73c0b94b92f7)
+++ benchmark/readyQ/transfer.cpp	(revision 5c231c17eaf89139bc7b23f158a6e0f3468ef04d)
@@ -12,4 +12,5 @@
 
 bool exhaust = false;
+volatile bool estop = false;
 
 bench_sem the_main;
@@ -42,8 +43,11 @@
 				if( to_miliseconds(timeHiRes() - start) > 5'000 ) {
 					std::cerr << "Programs has been blocked for more than 5 secs" << std::endl;
-					std::exit(1);
+					estop = true;
+					the_main.post();
+					goto END;
 				}
 			}
 		}
+		END:;
 		PRINT( std::cout | "Waiting done"; )
 	}
@@ -59,5 +63,5 @@
 	void lead() {
 		this->idx = ++lead_idx;
-		if(lead_idx > stop_count) {
+		if(lead_idx > stop_count || estop) {
 			PRINT( std::cout << "Leader " << this->id << " done" << std::endl; )
 			the_main.post();
@@ -88,6 +92,6 @@
 	}
 
-	static void main(void * arg) {
-		MyThread & self = *reinterpret_cast<MyThread*>(arg);
+	static void main(MyThread * arg) {
+		MyThread & self = *arg;
 		self.park();
 
@@ -101,5 +105,5 @@
 				self.wait();
 			}
-			if(lead_idx > stop_count) break;
+			if(lead_idx > stop_count || estop) break;
 		}
 	}
@@ -144,5 +148,6 @@
 			for(size_t i = 0; i < nthreads; i++) {
 				threads[i] = new MyThread( i );
-				handles[i] = new Fibre( MyThread::main, threads[i] );
+				handles[i] = new Fibre();
+				handles[i]->run( MyThread::main, threads[i] );
 			}
 
@@ -164,5 +169,4 @@
 				PRINT( std::cout << i << " joined" << std::endl; )
 				rechecks += thrd.rechecks;
-				// delete( handles[i] );
 				delete( threads[i] );
 			}
@@ -176,7 +180,8 @@
 	std::cout << "Number of processors    : " << nprocs << std::endl;
 	std::cout << "Number of threads       : " << nthreads << std::endl;
-	std::cout << "Total Operations(ops)   : " << stop_count << std::endl;
+	std::cout << "Total Operations(ops)   : " << (lead_idx - 1) << std::endl;
 	std::cout << "Threads parking on wait : " << (exhaust ? "yes" : "no") << std::endl;
 	std::cout << "Rechecking              : " << rechecks << std::endl;
+	std::cout << "ns per transfer         : " << std::fixed << (((double)(end - start)) / (lead_idx)) << std::endl;
 
 
Index: benchmark/readyQ/transfer.go
===================================================================
--- benchmark/readyQ/transfer.go	(revision 3613e25a2dfc24b60fe9f336c21f73c0b94b92f7)
+++ benchmark/readyQ/transfer.go	(revision 5c231c17eaf89139bc7b23f158a6e0f3468ef04d)
@@ -6,4 +6,5 @@
 	"math/rand"
 	"os"
+	"regexp"
 	"runtime"
 	"sync/atomic"
@@ -16,4 +17,5 @@
 	id uint64
 	idx uint64
+	estop uint64
 	seed uint64
 }
@@ -34,5 +36,5 @@
 
 func NewLeader(size uint64) (*LeaderInfo) {
-	this := &LeaderInfo{0, 0, uint64(os.Getpid())}
+	this := &LeaderInfo{0, 0, 0, uint64(os.Getpid())}
 
 	r := rand.Intn(10)
@@ -51,6 +53,7 @@
 }
 
-func waitgroup(idx uint64, threads [] MyThread) {
+func waitgroup(leader * LeaderInfo, idx uint64, threads [] MyThread, main_sem chan struct {}) {
 	start := time.Now()
+	Outer:
 	for i := 0; i < len(threads); i++ {
 		// fmt.Fprintf(os.Stderr, "Waiting for :%d (%d)\n", threads[i].id, atomic.LoadUint64(&threads[i].idx) );
@@ -61,5 +64,7 @@
 			if delta.Seconds() > 5 {
 				fmt.Fprintf(os.Stderr, "Programs has been blocked for more than 5 secs")
-				os.Exit(1)
+				atomic.StoreUint64(&leader.estop, 1);
+				main_sem <- (struct {}{})
+				break Outer
 			}
 		}
@@ -74,4 +79,9 @@
 		if i != me {
 			// debug!( "Leader waking {}", i);
+			defer func() {
+				if err := recover(); err != nil {
+					fmt.Fprintf(os.Stderr, "Panic occurred: %s\n", err)
+				}
+			}()
 			threads[i].sem <- (struct {}{})
 		}
@@ -84,5 +94,5 @@
 	atomic.StoreUint64(&leader.idx, nidx);
 
-	if nidx > stop_count {
+	if nidx > stop_count || atomic.LoadUint64(&leader.estop) != 0 {
 		// debug!( "Leader {} done", this.id);
 		main_sem <- (struct {}{})
@@ -92,5 +102,5 @@
 	// debug!( "====================\nLeader no {} : {}", nidx, this.id);
 
-	waitgroup(nidx, threads);
+	waitgroup(leader, nidx, threads, main_sem);
 
 	leader.next( uint64(len(threads)) );
@@ -146,5 +156,5 @@
 			waitleader( exhaust, leader, &threads[me], &r )
 		}
-		if atomic.LoadUint64(&leader.idx) > stop_count { break; }
+		if atomic.LoadUint64(&leader.idx) > stop_count || atomic.LoadUint64(&leader.estop) != 0 { break; }
 	}
 
@@ -155,12 +165,25 @@
 func main() {
 	// Benchmark specific command line arguments
-	exhaustOpt := flag.Bool("e", false, "Whether or not threads that have seen the new epoch should park instead of yielding.")
+	exhaustOpt := flag.String("e", "no", "Whether or not threads that have seen the new epoch should park instead of yielding.")
 
 	// General benchmark initialization and deinitialization
-	defer bench_init()()
-
-	exhaust := *exhaustOpt;
+	bench_init()
+
+	exhaustVal := *exhaustOpt;
+
+	var exhaust bool
+	re_yes := regexp.MustCompile("[Yy]|[Yy][Ee][Ss]")
+	re_no  := regexp.MustCompile("[Nn]|[Nn][Oo]")
+	if re_yes.Match([]byte(exhaustVal)) {
+		exhaust = true
+	} else if re_no.Match([]byte(exhaustVal)) {
+		exhaust = false
+	} else {
+		fmt.Fprintf(os.Stderr, "Unrecognized exhaust(-e) option '%s'\n", exhaustVal)
+		os.Exit(1)
+	}
+
 	if clock_mode {
-		fmt.Fprintf(os.Stderr, "Programs does not support fixed duration mode")
+		fmt.Fprintf(os.Stderr, "Programs does not support fixed duration mode\n")
 		os.Exit(1)
 	}
@@ -215,9 +238,10 @@
 		ws = "no"
 	}
-	p.Printf("Duration (ms)           : %f\n", delta.Milliseconds() )
+	p.Printf("Duration (ms)           : %d\n", delta.Milliseconds() )
 	p.Printf("Number of processors    : %d\n", nprocs )
 	p.Printf("Number of threads       : %d\n", nthreads )
-	p.Printf("Total Operations(ops)   : %15d\n", stop_count )
+	p.Printf("Total Operations(ops)   : %15d\n", (leader.idx - 1) )
 	p.Printf("Threads parking on wait : %s\n", ws)
 	p.Printf("Rechecking              : %d\n", rechecks )
-}
+	p.Printf("ns per transfer         : %f\n", float64(delta.Nanoseconds()) / float64(leader.idx) )
+}
Index: benchmark/readyQ/transfer.rs
===================================================================
--- benchmark/readyQ/transfer.rs	(revision 3613e25a2dfc24b60fe9f336c21f73c0b94b92f7)
+++ benchmark/readyQ/transfer.rs	(revision 5c231c17eaf89139bc7b23f158a6e0f3468ef04d)
@@ -6,5 +6,5 @@
 use std::hint;
 use std::sync::Arc;
-use std::sync::atomic::{AtomicUsize, Ordering};
+use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering};
 use std::time::{Instant,Duration};
 
@@ -44,5 +44,9 @@
 			match val {
 				"yes" => true,
+				"Y" => true,
+				"y" => true,
 				"no"  => false,
+				"N"  => false,
+				"n"  => false,
 				"maybe" | "I don't know" | "Can you repeat the question?" => {
 					eprintln!("Lines for 'Malcolm in the Middle' are not acceptable values of parameter 'exhaust'");
@@ -64,4 +68,5 @@
 	id: AtomicUsize,
 	idx: AtomicUsize,
+	estop: AtomicBool,
 	seed: u128,
 }
@@ -72,4 +77,5 @@
 			id: AtomicUsize::new(nthreads),
 			idx: AtomicUsize::new(0),
+			estop: AtomicBool::new(false),
 			seed: process::id() as u128
 		};
@@ -100,7 +106,7 @@
 }
 
-fn waitgroup(idx: usize, threads: &Vec<Arc<MyThread>>) {
+fn waitgroup(leader: &LeaderInfo, idx: usize, threads: &Vec<Arc<MyThread>>, main_sem: &sync::Semaphore) {
 	let start = Instant::now();
-	for t in threads {
+	'outer: for t in threads {
 		debug!( "Waiting for :{} ({})", t.id, t.idx.load(Ordering::Relaxed) );
 		while t.idx.load(Ordering::Relaxed) != idx {
@@ -108,5 +114,7 @@
 			if start.elapsed() > Duration::from_secs(5) {
 				eprintln!("Programs has been blocked for more than 5 secs");
-				std::process::exit(1);
+				leader.estop.store(true, Ordering::Relaxed);
+				main_sem.add_permits(1);
+				break 'outer;
 			}
 		}
@@ -131,5 +139,5 @@
 	leader.idx.store(nidx, Ordering::Relaxed);
 
-	if nidx as u64 > exp.stop_count {
+	if nidx as u64 > exp.stop_count || leader.estop.load(Ordering::Relaxed) {
 		debug!( "Leader {} done", this.id);
 		main_sem.add_permits(1);
@@ -139,5 +147,5 @@
 	debug!( "====================\nLeader no {} : {}", nidx, this.id);
 
-	waitgroup(nidx, threads);
+	waitgroup(leader, nidx, threads, main_sem);
 
 	leader.next( threads.len() );
@@ -192,5 +200,5 @@
 			wait( exhaust, &leader, &threads[me], &mut rechecks ).await;
 		}
-		if leader.idx.load(Ordering::Relaxed) as u64 > exp.stop_count { break; }
+		if leader.idx.load(Ordering::Relaxed) as u64 > exp.stop_count || leader.estop.load(Ordering::Relaxed) { break; }
 	}
 
@@ -273,6 +281,8 @@
 	println!("Number of processors    : {}", (nprocs).to_formatted_string(&Locale::en));
 	println!("Number of threads       : {}", (nthreads).to_formatted_string(&Locale::en));
-	println!("Total Operations(ops)   : {:>15}", (exp.stop_count).to_formatted_string(&Locale::en));
+	println!("Total Operations(ops)   : {:>15}", (leader.idx.load(Ordering::Relaxed) - 1).to_formatted_string(&Locale::en));
 	println!("Threads parking on wait : {}", if exhaust { "yes" } else { "no" });
 	println!("Rechecking              : {}", rechecks );
-}
+	println!("ns per transfer         : {}", ((duration.as_nanos() as f64) / leader.idx.load(Ordering::Relaxed) as f64));
+
+}