diff options
| author | Joel Galenson <jgalenson@google.com> | 2020-10-23 09:39:31 -0700 |
|---|---|---|
| committer | Joel Galenson <jgalenson@google.com> | 2020-10-23 09:52:09 -0700 |
| commit | d5495b03381a3ebe0805db353d198b285b535b5c (patch) | |
| tree | 778b8524d15fca8b73db0253ee0e1919d0848bb6 /src/runtime/tests/loom_pool.rs | |
| parent | ba45c5bedf31df8562364c61d3dfb5262f10642e (diff) | |
| download | tokio-d5495b03381a3ebe0805db353d198b285b535b5c.tar.gz | |
Update to tokio-0.3.1 and add new features
Test: Build
Change-Id: I5b5b9b386a21982a019653d0cf0bd3afc505cfac
Diffstat (limited to 'src/runtime/tests/loom_pool.rs')
| -rw-r--r-- | src/runtime/tests/loom_pool.rs | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/runtime/tests/loom_pool.rs b/src/runtime/tests/loom_pool.rs index c08658c..06ad641 100644 --- a/src/runtime/tests/loom_pool.rs +++ b/src/runtime/tests/loom_pool.rs @@ -178,7 +178,7 @@ mod group_b { #[test] fn join_output() { loom::model(|| { - let mut rt = mk_pool(1); + let rt = mk_pool(1); rt.block_on(async { let t = crate::spawn(track(async { "hello" })); @@ -192,7 +192,7 @@ mod group_b { #[test] fn poll_drop_handle_then_drop() { loom::model(|| { - let mut rt = mk_pool(1); + let rt = mk_pool(1); rt.block_on(async move { let mut t = crate::spawn(track(async { "hello" })); @@ -209,7 +209,7 @@ mod group_b { #[test] fn complete_block_on_under_load() { loom::model(|| { - let mut pool = mk_pool(1); + let pool = mk_pool(1); pool.block_on(async { // Trigger a re-schedule @@ -296,9 +296,8 @@ mod group_d { } fn mk_pool(num_threads: usize) -> Runtime { - runtime::Builder::new() - .threaded_scheduler() - .core_threads(num_threads) + runtime::Builder::new_multi_thread() + .worker_threads(num_threads) .build() .unwrap() } |