parallel.foreach 相关问题

我对 Rust 很陌生，并试图在 Rust 中创建 C# 的 Parallel.Run 方法。 C#代码 Parallel.ForEach（集合，x => { // 用 x 做点什么 }) 防锈代码 pub async fn parallel_run 我对 Rust 很陌生，并试图在 Rust 中创建 C# 的 Parallel.Run 方法。 C#代码 Parallel.ForEach(collection, x => { // do something with x }) 防锈代码 pub async fn parallel_run<T>(collection: Vec<T>, callback: fn(item: T) -> dyn Future<Output= ()>){ {  for item in collection {  tokio::spawn(callback(item)).await.expect("TODO: panic message"); }  }  编译错误类型值的大小dyn Future<Output = ()> 在编译时无法知道 [E0277] 在编译时帮助中没有已知大小：特性 Sized 没有为 dyn Future<Output = ()> 实现注意：tokio::spawn 中的绑定要求 dyn Future<Output = ()>不能在线程间发送安全地 [E0277] 求助：特性 Send 未实现 dyn Future<Output = ()> 注意：tokio::spawn 中的绑定要求我错过了什么？？我需要在 rust 中重新创建 Parallel.ForEach 等价物如果你只需要一些计算（CPU 绑定任务），你可以使用 rayon 并行过滤和平方值的例子： use rayon::iter::{IntoParallelRefIterator, ParallelIterator}; fn my_complex_calculation(v: i32)->i32 { v*v } fn main(){ let values = vec![1,2,3,4,5,6,7,8,9,10]; let updated: Vec<i32> = values.par_iter() .filter(|&&x| x & 1 == 0) .copied() .map(my_complex_calculation) .collect(); assert_eq!(*updated, [4,16,36,64,100]); } 如果您需要并行执行一些异步任务并等待所有这些任务，您可以使用 JoinSet 来自 tokio. use tokio::task::JoinSet; async fn my_network_request(v: i32)->i32 { // Write your code here. v*v } #[tokio::main] async fn main(){ let values = vec![1,2,3,4,5,6,7,8,9,10]; let mut results = vec![0; values.len()]; let mut join_set = JoinSet::new(); for (i, &v) in values.iter().enumerate(){ join_set.spawn(async move { (i, my_network_request(v).await) }); } while let Some(res) = join_set.join_next().await { let(idx, val) = res.unwrap(); results[idx] = val; } assert_eq!(*results, [1, 4, 9, 16,25, 36,49, 64,81,100]); }

c# rust parallel-processing task-parallel-library parallel.foreach

回答 1 投票 0

如何将 Parallel.ForEach(..) 用于 Regex.EnumerateMatches(ReadOnlySpan<char>)

我正在使用（为了提高速度）“RegexSrcGenerator”并且有一个像这样的正则表达式： var 我的正则表达式 = SrcGen.CachedRegex; //这是我用来迭代的： foreach（正则表达式中的 ValueMatch 匹配。

c# regex parallel.foreach

回答 0 投票 0

如何将 Parallel.ForEach(..) 用于 Regex.EnumerateMatches(ReadOnlySpan<char>)

c# regex parallel.foreach

回答 0 投票 0

诊断显示（Visual Studio）中的 CPU 使用率是否错误？似乎显示的线程使用量比我计算的要少

我的项目需要最高性能，但诊断显示从未显示超过 5-10% 的处理器使用率。尽管将工作并行化并分配了所有可用的内核......

c# .net visual-studio parallel.foreach