Concurrent Chunk Processing
Implement controlled concurrency.
Add options:
concurrency: n
ordered: true | false
timeout: ...
Internally evaluate:
- Task.async_stream
- supervised workers
- partitioned execution
Benchmark:
- 1 worker
- scheduler count
- 2x scheduler count
Measure scaling characteristics.
Concurrent Chunk Processing
Implement controlled concurrency.
Add options:
Internally evaluate:
Benchmark:
Measure scaling characteristics.