I have multiple threads doing a computation and want to collect the results into a pre-allocated vector. To turn off the borrow checker, I wrote the function: fn set_unsync(vec: &Vec<usize&g...

Context I have a case where multiple threads must update objects stored in a shared vector. However, the vector is very large, and the number of elements to update is relatively small. Problem I...

So, I've been running out of memory with wasm/rust with +atomic flag and wanted to check how much memory is practically available. Here is my crude minimal working example that logs the memory of a...

I would like to create a large Polars DataFrame using Rust, building it up row by row using data scraped from web pages. What is an efficient way to do this? It looks like the DataFrame should be c...

I'm using the Rayon library: extern crate rayon; const N: usize = 1_000_000_000; const W: f64 = 1f64/(N as f64); fn f(x: f64) -> f64 { 4.0/(1.0+x*x) } fn main() { use rayon::prelude::*; l...

It's a common trick to annotate your functions with returning Result<X, Box<dyn Error>> to allow them to return any error at all. However, you can't return this from a thread without th...

I'm trying to get a simple timer set up in rust that returns true at a certain frequency. #[derive(Clone, Debug)] pub struct IntervalTimer { pub period: Duration, pub delta: Instant, } impl Inte...

I can iterate and process both index and the variable within such as: let x = vec![5, 6, 7, 8]; for (index, val) in x.iter().enumerate() { println!("{} {}", val, index); } Now with ray...

I am trying to optimize my function using Rayon's par_iter(). The single threaded version is something like: fn verify_and_store(store: &mut Store, txs: Vec<Tx>) { let result = txs.it...

I turn a regex into a HashSet after doing some filtering. I am trying to use it with Rayon, but I can't figure out how to make Rayon work with an existing iterator without converting it to a vector...

Rayon looks great for algorithm parallelization of collections, and Faster is great for vectorization (SIMD) on the x86 platform for collections like Vec<f32>. I've tried to combine them and ...

I am using Rayon to produce reasonably large return values. This uses a lot of memory when collecting all returned values into a Vec. Is there a way to avoid creating a Vec and directly consuming a...

I was hoping to replace an iter() with Rayon's par_iter() in a rather simple case like this, but I am failing to do so. The previous code: indexes_to_increment .iter() .for_each(|x| self.some_d...

I'm attempting to parallelise the Ramer–Douglas-Peucker line simplification algorithm by using Rayon's par_iter instead of iter: extern crate num_traits; use num_traits::{Float, ToPrimitive}; exte...

This is a contrived example but I believe if I can get this working I can apply it to my specific case. extern crate num; extern crate rayon; use rayon::prelude::*; use num::Float; fn sqrts<T:...

I have a struct which implements Iterator and it works fine as an iterator. It produces values, and using .map(), I download each item from a local HTTP server and save the results. I now want to p...