Searched refs:par_iter (Results 1 – 11 of 11) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/ |
| D | core.rs | 30 pub(crate) async fn core<P, C>(par_iter: P, consumer: C) -> Result<C::Output, ScheduleError> in core()
40 AsyncHandle::CurrentThread(_) => Ok(consumer.consume(par_iter)), in core()
48 par_iter, in core()
61 par_iter, in core()
75 par_iter: P, in recur()
84 if (par_iter.len() >> 1) <= min_split_len || split_time == 0 { in recur()
85 return Ok(consumer.consume(par_iter)); in recur()
87 let (left, right) = par_iter.split(); in recur()
127 par_iter: P, in spawn_task()
141 par_iter, in spawn_task()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/pariter/ |
| D | sum.rs | 20 pub async fn sum<P>(par_iter: P) -> Result<P::Item, ScheduleError> in sum()
26 par_iter.drive(consumer).await in sum()
37 fn consume(&self, par_iter: P) -> Self::Output { in consume()
38 par_iter.iter().sum() in consume()
|
| D | for_each.rs | 17 pub async fn for_each<P, F>(par_iter: P, f: F) -> Result<(), ScheduleError> in for_each()
23 par_iter.drive(consumer).await in for_each()
42 fn consume(&self, par_iter: P) -> Self::Output { in consume()
43 par_iter.iter().for_each(&self.f) in consume()
|
| D | map.rs | 18 pub fn map<P, F>(par_iter: P, map_op: F) -> Map<P, F> { in map()
20 base: par_iter, in map()
|
| D | filter.rs | 18 pub fn filter<P, F>(par_iter: P, predicate: F) -> Filter<P, F> { in filter()
20 base: par_iter, in filter()
|
| D | mod.rs | 128 fn consume(&self, par_iter: P) -> Self::Output; in consume()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | par_iter.rs | 29 .par_iter() in sdv_par_iter_test()
32 .zip(b.par_iter()) in sdv_par_iter_test()
|
| D | entry.rs | 27 mod par_iter; module
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/ |
| D | mod.rs | 72 fn par_iter(&'a self) -> ParIter<Self::Data>; in par_iter() method
80 fn par_iter(&'a self) -> ParIter<Self::Data> { in par_iter() function
|
| /commonlibrary/rust/ylong_runtime/ |
| D | RELEASE_NOTES.md | 8 - par_iter: asynchronous parallel iterator
|
| /commonlibrary/rust/ylong_runtime/docs/ |
| D | user_guide.md | 167 let sum = v.par_iter().map(|x| fibbo(*x)).sum().await.unwrap();
|