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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
--- rust-crossbeam-channel-0.5.4.orig/benches/crossbeam.rs
+++ rust-crossbeam-channel-0.5.4/benches/crossbeam.rs
@@ -37,7 +37,7 @@ mod unbounded {
#[bench]
fn par_inout(b: &mut Bencher) {
- let threads = num_cpus::get();
+ let threads = num_cpus::get().clamp(2,8);
let steps = TOTAL_STEPS / threads;
let (s, r) = unbounded::<i32>();
@@ -100,7 +100,7 @@ mod unbounded {
#[bench]
fn spmc(b: &mut Bencher) {
- let threads = num_cpus::get() - 1;
+ let threads = (num_cpus::get() - 1).clamp(2,8);
let steps = TOTAL_STEPS / threads;
let (s, r) = unbounded::<i32>();
@@ -136,7 +136,7 @@ mod unbounded {
#[bench]
fn mpsc(b: &mut Bencher) {
- let threads = num_cpus::get() - 1;
+ let threads = (num_cpus::get() - 1).clamp(2,8);
let steps = TOTAL_STEPS / threads;
let (s, r) = unbounded::<i32>();
@@ -172,7 +172,7 @@ mod unbounded {
#[bench]
fn mpmc(b: &mut Bencher) {
- let threads = num_cpus::get();
+ let threads = num_cpus::get().clamp(4,16);
let steps = TOTAL_STEPS / threads;
let (s, r) = unbounded::<i32>();
@@ -248,7 +248,7 @@ mod bounded_n {
#[bench]
fn spmc(b: &mut Bencher) {
- let threads = num_cpus::get() - 1;
+ let threads = (num_cpus::get() - 1).clamp(2,8);
let steps = TOTAL_STEPS / threads;
let (s, r) = bounded::<i32>(steps * threads);
@@ -284,7 +284,7 @@ mod bounded_n {
#[bench]
fn mpsc(b: &mut Bencher) {
- let threads = num_cpus::get() - 1;
+ let threads = (num_cpus::get() - 1).clamp(2,8);
let steps = TOTAL_STEPS / threads;
let (s, r) = bounded::<i32>(steps * threads);
@@ -320,7 +320,7 @@ mod bounded_n {
#[bench]
fn par_inout(b: &mut Bencher) {
- let threads = num_cpus::get();
+ let threads = num_cpus::get().clamp(2,8);
let steps = TOTAL_STEPS / threads;
let (s, r) = bounded::<i32>(threads);
@@ -354,7 +354,7 @@ mod bounded_n {
#[bench]
fn mpmc(b: &mut Bencher) {
- let threads = num_cpus::get();
+ let threads = num_cpus::get().clamp(4,16);
assert_eq!(threads % 2, 0);
let steps = TOTAL_STEPS / threads;
let (s, r) = bounded::<i32>(steps * threads);
@@ -445,7 +445,7 @@ mod bounded_1 {
#[bench]
fn spmc(b: &mut Bencher) {
- let threads = num_cpus::get() - 1;
+ let threads = (num_cpus::get() - 1).clamp(2,8);
let steps = TOTAL_STEPS / threads;
let (s, r) = bounded::<i32>(1);
@@ -481,7 +481,7 @@ mod bounded_1 {
#[bench]
fn mpsc(b: &mut Bencher) {
- let threads = num_cpus::get() - 1;
+ let threads = (num_cpus::get() - 1).clamp(2,8);
let steps = TOTAL_STEPS / threads;
let (s, r) = bounded::<i32>(1);
@@ -517,7 +517,7 @@ mod bounded_1 {
#[bench]
fn mpmc(b: &mut Bencher) {
- let threads = num_cpus::get();
+ let threads = num_cpus::get().clamp(4,16);
let steps = TOTAL_STEPS / threads;
let (s, r) = bounded::<i32>(1);
@@ -598,7 +598,7 @@ mod bounded_0 {
#[bench]
fn spmc(b: &mut Bencher) {
- let threads = num_cpus::get() - 1;
+ let threads = (num_cpus::get() - 1).clamp(2,8);
let steps = TOTAL_STEPS / threads;
let (s, r) = bounded::<i32>(0);
@@ -634,7 +634,7 @@ mod bounded_0 {
#[bench]
fn mpsc(b: &mut Bencher) {
- let threads = num_cpus::get() - 1;
+ let threads = (num_cpus::get() - 1).clamp(2,8);
let steps = TOTAL_STEPS / threads;
let (s, r) = bounded::<i32>(0);
@@ -670,7 +670,7 @@ mod bounded_0 {
#[bench]
fn mpmc(b: &mut Bencher) {
- let threads = num_cpus::get();
+ let threads = num_cpus::get().clamp(4,16);
let steps = TOTAL_STEPS / threads;
let (s, r) = bounded::<i32>(0);
|
