Skip to content

Commit e0331db

Browse files
committed
pin event-listener to avoid hang
1 parent 9f5f562 commit e0331db

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@ async-channel = "1.1"
4949
bincode = { version = "1.3", optional = true }
5050
constellation-rs = { version = "0.2.0-alpha.2", default-features = false, optional = true }
5151
derive-new = "0.5"
52+
event-listener = "=2.3.1" # https://github.com/stjepang/event-listener/issues/9
5253
futures = "0.3"
5354
num_cpus = "1.13"
5455
pin-project = "0.4"

src/pool/thread.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -275,9 +275,9 @@ mod pool {
275275
};
276276

277277
#[tokio::test]
278-
async fn spawn_pinned_() {
278+
async fn spawn_pinned() {
279279
const TASKS: usize = 1000;
280-
const ITERS: usize = 1000;
280+
const ITERS: usize = 200;
281281
const THREADS: usize = 4;
282282
let pool = Pool::new(THREADS);
283283
let count = Arc::new(AtomicUsize::new((1..TASKS).sum()));

0 commit comments

Comments
 (0)