From 036c8529dc10c88d60e9b78d289ccb2d74332bc9 Mon Sep 17 00:00:00 2001
From: "Christoph J. Scherr" <Christoph.Scherr@newtec.de>
Date: Thu, 1 Feb 2024 17:21:52 +0100
Subject: [PATCH] refactoring

---
 members/tokryon/src/main.rs | 21 ++++++++++-----------
 1 file changed, 10 insertions(+), 11 deletions(-)

diff --git a/members/tokryon/src/main.rs b/members/tokryon/src/main.rs
index 6696641..c0008b4 100644
--- a/members/tokryon/src/main.rs
+++ b/members/tokryon/src/main.rs
@@ -3,8 +3,8 @@ use std::io::prelude::*;
 use tokio::time::Instant;
 
 // if we make these larger, our computer can be used as a heater🔥
-type Danum = u16;
-const EXP: usize = 12; // FIXME: If this goes lower than 7, somehow the mpsc breaks?
+type Danum = u16; // you wont see any statuses for a long time with anything bigger than u16
+const EXP: usize = 8; // FIXME: If this goes lower than 7, somehow the mpsc breaks?
 const CAP: usize = 1 << EXP;
 const M: u128 = CAP as u128 * Danum::MAX as u128;
 
@@ -57,14 +57,7 @@ async fn main() {
     // stops earlier sometimes
     let (sender, recv) = std::sync::mpsc::channel();
     rayon::spawn(move || {
-        for i in 0..separate + 1 {
-            match sender.send((range.par_iter().map(|n| *n as u128).sum(), i)) {
-                Ok(_) => (),
-                Err(err) => {
-                    eprintln!("{err}");
-                    break;
-                }
-            }
+        for i in 0..separate {
             range
                 .par_iter_mut()
                 .skip(i)
@@ -75,8 +68,14 @@ async fn main() {
                         let _ = write!(std::io::Sink::default(), "{num}");
                     }
                 });
+            match sender.send((range.par_iter().map(|n| *n as u128).sum(), i + 1)) {
+                Ok(_) => (),
+                Err(err) => {
+                    eprintln!("{err}");
+                    break;
+                }
+            }
         }
-        println!("DONE!");
     });
     loop {
         match recv.recv() {