refactoring
Cargo Check, Format, Fix and Test / cargo CI (push) Successful in 1m22s
Details
Cargo Check, Format, Fix and Test / cargo CI (push) Successful in 1m22s
Details
This commit is contained in:
parent
86c0743c8b
commit
e56dfceaa8
|
@ -57,14 +57,7 @@ async fn main() {
|
||||||
// stops earlier sometimes
|
// stops earlier sometimes
|
||||||
let (sender, recv) = std::sync::mpsc::channel();
|
let (sender, recv) = std::sync::mpsc::channel();
|
||||||
rayon::spawn(move || {
|
rayon::spawn(move || {
|
||||||
for i in 0..separate + 1 {
|
for i in 0..separate {
|
||||||
match sender.send((range.par_iter().map(|n| *n as u128).sum(), i)) {
|
|
||||||
Ok(_) => (),
|
|
||||||
Err(err) => {
|
|
||||||
eprintln!("{err}");
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
range
|
range
|
||||||
.par_iter_mut()
|
.par_iter_mut()
|
||||||
.skip(i)
|
.skip(i)
|
||||||
|
@ -75,8 +68,14 @@ async fn main() {
|
||||||
let _ = write!(std::io::Sink::default(), "{num}");
|
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 {
|
loop {
|
||||||
match recv.recv() {
|
match recv.recv() {
|
||||||
|
|
Loading…
Reference in New Issue