Struct WorkerPool

pub struct WorkerPool<W>
where
    W: InnerWorker,
{ /* private fields */ }

Available on crate feature worker only.

A pool of worker threads that can be used to run javascript code in parallel Uses a round-robin strategy to distribute work between workers Each worker is an independent runtime instance

Implementations

impl<W> WorkerPool<W>

where W: InnerWorker,

pub fn new(options: W::RuntimeOptions, n_workers: u32) -> Result<Self, Error>

Create a new worker pool with the specified number of workers

Errors

Can fail if a runtime cannot be initialized (usually due to extension issues)

pub fn options(&self) -> &W::RuntimeOptions

Returns the runtime options used by the workers in the pool

pub fn shutdown(self)

Stop all workers in the pool and wait for them to finish

pub fn len(&self) -> usize

Get the number of workers in the pool

pub fn is_empty(&self) -> bool

Check if the pool is empty This will be true if the pool has no workers This can happen if the pool was created with 0 workers Which is not particularly useful, but is allowed

pub fn worker_by_id(&self, id: usize) -> Option<Rc<RefCell<Worker<W>>>>

Get a worker by its index in the pool

pub fn next_worker(&mut self) -> Rc<RefCell<Worker<W>>>

Get the next worker in the pool

pub fn send_and_await(&mut self, query: W::Query) -> Result<W::Response, Error>

Send a request to the next worker in the pool This will block the current thread until the response is received

Errors

Will return an error if the worker has already been stopped, or if the worker thread panicked

pub fn eval_in_thread<T>(code: String) -> JoinHandle<Result<T, Error>>

where T: DeserializeOwned + Send + 'static,

Evaluate a string of non-ecma javascript code in a separate thread The code is evaluated in a new runtime instance, which is then destroyed Returns a handle to the thread that is running the code