Struct GraphThreadPool 

pub struct GraphThreadPool { /* private fields */ }

Thread pool for concurrent graph operations

Implementations

impl GraphThreadPool

pub fn new() -> Result<Self>

Create a new graph thread pool

pub fn with_config(num_threads: usize, max_batch_size: usize) -> Result<Self>

Create a thread pool with custom configuration

pub fn process_triples<F, R>( &self, triples: Vec<Triple>, processor: F, ) -> Vec<R>

where F: Fn(Triple) -> R + Sync + Send, R: Send,

Process triples concurrently

pub fn process_graphs<F, R>(&self, graphs: Vec<Graph>, processor: F) -> Vec<R>

where F: Fn(Graph) -> R + Sync + Send, R: Send,

Process graph operations concurrently

pub fn merge_graphs(&self, graphs: Vec<Graph>) -> Graph

Parallel merge multiple graphs

pub fn inner(&self) -> &ThreadPool

Get the underlying thread pool (only available with parallel feature)

Trait Implementations

impl Default for GraphThreadPool

fn default() -> Self

Returns the “default value” for a type.