core: Implement concurrent read for blocking read
Does this require an RFC or can it be done directly?
Does this require an RFC or can it be done directly?
We can do it directly but I want to know about your design first.
There are two scenarios:
- We have an
Range, split it intoconcurrentintervals and read it usingrayon - No
Range, read in parallel withconcurrentusing1024 * 1024 * 4until we reach the end
Do you have more details? What's the API will look like? How do we share the concurrent features between BlockingReader, StdReader and StdIterator?
We add a field OpReader into BlockingReader and use it concurrent read in method read_at and read_into.
We add a field
OpReaderinto BlockingReader and use it concurrent read in methodread_atandread_into.
I'm not sure if we are aligned. Please feel free to give it a try.
Closing as no user really want this.