arty 0.6.0

Thread-aware async runtime that keeps each task on one worker thread.
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

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

//! Worker routing, submission capabilities, and stop coordination.
//!
//! `DispatcherCore` owns the worker endpoints and maps threads to workers.
//! `DispatcherClient` is the cloneable handle that schedulers and workers use.

mod client;
mod core;
pub(crate) use core::WorkerIndex;
pub(super) use core::{DispatcherCore, WorkerEndpoint};

pub(crate) use client::DispatcherClient;

#[cfg(test)]
fn test_threads(count: usize) -> Vec<thread_aware::Thread> {
    let builder = thread_aware::ThreadBuilder::default();
    (0..count)
        .map(|_| {
            let builder = builder.clone();
            std::thread::spawn(move || builder.build(std::thread::current().id()))
                .join()
                .unwrap()
        })
        .collect()
}