taskorch 0.3.0

Concurrent Pool for task processing
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61


use taskorch::{Pool, Queue, TaskBuildNew, TaskSubmitter};

// Thread 1: Task execution (consumer) role
// Thread 2: Task generation (producer) role

fn main() {
    println!("----- test task orch -----");

    // Step#1. create a Pool
    let mut pool = Pool::new();

    // Step#2. create a queue
    let qid1 = pool.insert_queue(&Queue::new()).unwrap();
    let submitter1 = pool.task_submitter(qid1).unwrap();
    // Step#4. start a thread and run
    pool.spawn_thread_for(qid1);

    // Step#3. create tasks
    consume_task_prompt(&submitter1);

    std::thread::spawn(||{
        produce_task(submitter1);
    });

    // Step#5. wait until all finished
    pool.join();
}

fn consume_task_prompt(submitter:&TaskSubmitter) {
    submitter.submit((||println!("Init: waiting task to do")).into_task());
}

fn produce_task(submitter:TaskSubmitter) {
    prompt("hello");
    submitter.submit((||println!("consmue task='hello': hello everyone!")).into_task());

    prompt("exit");
    let id_exit = submitter.submit((|a:i32|println!("consume task='exit': recv cond={a} and exit.")).into_exit_task())
        .take();

    prompt("add");
    let id_add = submitter.submit(
        (|a:i32,b:i32|{
            println!("consume task='add': ({a},{b}) and then pass (r={}) to Task='exit'",a+b);
            a+b
        }).into_task().bind_to(id_exit.input_ca::<0>())
    ).take();

    prompt("params");
    let _ = submitter.submit(
        (||{println!("consume task='params': pass (1,2) to task='add'");1},10.into())
        .into_task()
        .map_tuple_with(move|_:i32| (1,2))
        .bind_all_to((id_add.input_ca::<0>(),id_add.input_ca::<1>()))
    );
}

fn prompt(taskname:&'static str) {
    println!("produce task='{taskname}'.");
}