Struct RayonFiles 

pub struct RayonFiles<File> { /* private fields */ }

Wrapper data structure for multiple files to be used with [rayon] thread pool, where the same file is opened multiple times, once for each thread for faster concurrent reads

Implementations

impl RayonFiles<File>

pub fn open<P>(path: P) -> Result<Self>

where P: AsRef<Path>,

Open file at specified path as many times as there is number of threads in current [rayon] thread pool.

impl<File> RayonFiles<File>

where File: ReadAtSync,

pub fn open_with<P>(path: P, open: fn(&Path) -> Result<File>) -> Result<Self>

where P: AsRef<Path>,

Open file at specified path as many times as there is number of threads in current [rayon] thread pool with a provided function

Trait Implementations

impl<File: Debug> Debug for RayonFiles<File>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<File> ReadAtSync for &RayonFiles<File>

where File: ReadAtSync,

fn read_at(&self, buf: &mut [u8], offset: u64) -> Result<()>

Fill the buffer by reading bytes at a specific offset

fn offset(&self, offset: u64) -> ReadAtOffset<'_, Self>

where Self: Sized,

Get implementation of ReadAtSync that add specified offset to all attempted reads

impl<File> ReadAtSync for RayonFiles<File>

where File: ReadAtSync,

fn read_at(&self, buf: &mut [u8], offset: u64) -> Result<()>

Fill the buffer by reading bytes at a specific offset

fn offset(&self, offset: u64) -> ReadAtOffset<'_, Self>

where Self: Sized,

Get implementation of ReadAtSync that add specified offset to all attempted reads