executors 0.10.0

A collection of high-performance task executors.
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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

[package]
name = "executors"
# NB: When modifying, also modify:
#   1. html_root_url in lib.rs
#   2. number in readme (for breaking changes)
version = "0.10.0"
authors = ["Lars Kroll <lkroll@kth.se>"]
edition = "2021"
description = "A collection of high-performance task executors."
documentation = "https://docs.rs/executors"
homepage = "https://github.com/Bathtor/rust-executors"
repository = "https://github.com/Bathtor/rust-executors"
readme = "../README.md"
keywords = ["executor", "concurrency", "thread"]
categories = ["concurrency", "asynchronous"]
license = "MIT"

[features]
default = [
    "threadpool-exec",
    "cb-channel-exec",
    "workstealing-exec",
    "ws-timed-fairness",
    "defaults",
]

threadpool-exec = ["threadpool"]
cb-channel-exec = ["crossbeam-channel", "async-task"]
workstealing-exec = [
    "crossbeam-channel",
    "crossbeam-deque",
    "rand",
    "crossbeam-utils",
    "async-task",
]
defaults = ["num_cpus"]

# In the workstealing executor, check the global queues every 1ms
ws-timed-fairness = []
# Otherwise check the global queues every 100 jobs

# In the workstealing executor, never park worker threads
ws-no-park = []

thread-pinning = ["core_affinity"]
numa-aware = ["thread-pinning"]

produce-metrics = ["metrics"]


[dependencies]
log = "0.4"
synchronoise = "1.0"
arr_macro = "0.2"
crossbeam-channel = { version = "0.5", optional = true }
threadpool = { version = "1.8", optional = true }
crossbeam-utils = { version = "0.8", optional = true }
crossbeam-deque = { version = "0.8", optional = true }
rand = { version = "0.8", optional = true }
num_cpus = { version = "1", optional = true }
core_affinity = { version = "0.8", optional = true }
async-task = { version = "4.0", optional = true }
metrics = { version = "0.24", optional = true }
# reintroduce once hwloc is more stable or replace if there's an alternative
#hwloc2 				= {version = "2.2", optional = true}

[dev-dependencies]
env_logger = "0.11"
version-sync = "0.9"
criterion = "0.5"
futures = "0.3"
metrics_printer = "0.1"


[badges]
# Maintenance: `status` is required Available options are `actively-developed`,
# `passively-maintained`, `as-is`, `none`, `experimental`, `looking-for-maintainer`
# and `deprecated`.
maintenance = { status = "passively-maintained" }

[[bench]]
name = "scheduler"
path = "benches/scheduler.rs"
harness = false

[package.metadata.docs.rs]

features = ["numa-aware"]