Expand description
ParallelTaskIter is the underlying trait for a data parallelism library built on the ‘pull’ approach.
Modules§
- collector
- Collector is a trait that can be implemented across Collections and other types that implement Extend trait. For instance here it has been implemented for Vector, HashMap and so on. This allows the end result to collected in the desired form as per the annotation.
- errors
- for_
each - iterators
- map
- prelude
- task_
queue - worker_
thread - WorkerThreads enables the launching of thread pool that manages the running of closures based on inputs from the Iterator. This follows a pull phiolosophy and thus threads run till there are Items to pull from the AtomicIterator. Whenever a thread becomes free it pulls a new Item and runs the closure function on the same