node-workers 0.8.0

A pool of long-lived nodejs workers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

use node_workers::{EmptyPayload, WorkerPool};

fn main() {
  {
    let mut pool = WorkerPool::setup("examples/worker", 2);
    pool.with_debug(true);
    let payloads = vec![10, 20, 30, 40];
    let result = pool.perform::<u64, _>("fib2", payloads).unwrap();
    println!("-----");
    println!("result: {:?}", result);
  }

  {
    // Using serde, results from workers can be deserialized into structs
    use serde::{Deserialize, Serialize};
    #[derive(Serialize, Deserialize, Debug)]
    struct Person {
      name: String,
      age: u8,
      phones: Vec<String>,
    }

    let mut pool = WorkerPool::setup("examples/worker", 2);
    let result = pool
      .perform::<Person, _>("getUser", vec![EmptyPayload::new()])
      .unwrap();
    println!("-----");
    println!("result: {:?}", result);
  }
}