summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--posts/parseq.md13
1 files changed, 7 insertions, 6 deletions
diff --git a/posts/parseq.md b/posts/parseq.md
index 2e3b607..eb7c159 100644
--- a/posts/parseq.md
+++ b/posts/parseq.md
@@ -2,6 +2,7 @@
title: "Parseq"
description: "A parallel sequential iterator for Rust."
published: 2022-12-20
+updated: 2023-03-25
---
I've published my own parallel sequential iterator library for Rust, [Parseq](https://crates.io/crates/parseq).
@@ -11,16 +12,16 @@ It's a drop-in-replacement for the standard [`map`](https://doc.rust-lang.org/st
use std::time::Duration;
use parseq::ParallelIterator;
- let mut iter = (0..3)
+ let mut iter = [3,2,1]
.into_iter()
.map_parallel(|i| {
// Insert heavy computation here ...
- std::thread::sleep(Duration::from_millis((i % 3) * 10));
- i
+ std::thread::sleep(Duration::from_millis(100*i));
+ 2*i
});
-
- assert_eq!(iter.next(), Some(0));
- assert_eq!(iter.next(), Some(1));
+
+ assert_eq!(iter.next(), Some(6));
+ assert_eq!(iter.next(), Some(4));
assert_eq!(iter.next(), Some(2));
assert_eq!(iter.next(), None);
Generated by cgit. See skreutz.com for my tech blog and contact information.