Struct VibeSystem 

pub struct VibeSystem { /* private fields */ }

The main entry point for the simple parallel execution system.

Implementations

impl VibeSystem

pub fn new() -> Self

Creates a new VibeSystem with sensible default settings.

This initializes the background worker pools and load balancer.

pub fn run<F, T, R>(&self, func: F, data: T) -> Job<R>

where F: FnOnce(T) -> R + Send + 'static, T: Send + 'static, R: Send + 'static,

Runs a function with input data in parallel.

This method takes a function and its input data, submits it to the system for background execution, and immediately returns a Job handle.

Example

let job = system.run(process_data, my_data);

pub fn go<F, R>(&self, func: F) -> Job<R>

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

Runs a function with no input data in parallel.

This is a convenience wrapper around run for functions that take no arguments.

Example

let job = system.go(|| expensive_calculation());

Trait Implementations

impl Default for VibeSystem

fn default() -> Self

Returns the “default value” for a type.