Searched refs:LocalPool (Results 1 – 10 of 10) sorted by relevance
| /external/rust/crates/futures-executor/tests/ |
| D | local_pool.rs | 2 use futures::executor::LocalPool;
32 let mut pool = LocalPool::new(); in run_until_single_future()
44 let mut pool = LocalPool::new(); in run_until_ignores_spawned()
53 let mut pool = LocalPool::new(); in run_until_executes_spawned()
63 let mut pool = LocalPool::new(); in run_returns_if_empty()
73 let mut pool = LocalPool::new(); in run_executes_spawned()
95 let mut pool = LocalPool::new(); in run_spawn_many()
112 let mut pool = LocalPool::new(); in try_run_one_returns_if_empty()
122 let mut pool = LocalPool::new(); in try_run_one_executes_one_ready()
150 let mut pool = LocalPool::new(); in try_run_one_returns_on_no_progress()
[all …]
|
| /external/rust/crates/futures-util/benches_disabled/ |
| D | bilock.rs | 6 use futures::executor::LocalPool;
57 let pool = LocalPool::new(); in contended()
96 let pool = LocalPool::new(); in lock_unlock()
|
| /external/rust/crates/futures-executor/src/ |
| D | local_pool.rs | 28 pub struct LocalPool { struct
119 impl LocalPool { impl
303 impl Default for LocalPool { implementation
358 LocalPool::new().run_until(self.stream.next()) in next()
|
| D | lib.rs | 52 pub use crate::local_pool::{block_on, block_on_stream, BlockingStream, LocalPool, LocalSpawner};
|
| /external/rust/crates/futures/tests/ |
| D | shared.rs | 112 use futures::executor::LocalPool; in peek()
116 let mut local_pool = LocalPool::new(); in peek()
|
| D | auto_traits.rs | 200 assert_not_impl!(LocalPool: Send);
201 assert_not_impl!(LocalPool: Sync);
202 assert_impl!(LocalPool: Unpin);
|
| /external/crosvm/cros_async/src/sync/ |
| D | cv.rs | 457 use futures_executor::{LocalPool, LocalSpawner, ThreadPool};
564 let mut ex = LocalPool::new(); in notify_one_single_thread_async()
860 let mut ex = LocalPool::new(); in notify_all_single_thread_async()
|
| D | mu.rs | 898 use futures_executor::{LocalPool, ThreadPool};
957 let mut ex = LocalPool::new(); in async_smoke()
1111 let mut ex = LocalPool::new(); in single_thread_async()
1295 let mut ex = LocalPool::new(); in rw_single_thread_async()
|
| /external/libchromeos-rs/src/sync/ |
| D | cv.rs | 492 use futures_executor::{LocalPool, LocalSpawner, ThreadPool};
600 let mut ex = LocalPool::new(); in notify_one_single_thread_async()
896 let mut ex = LocalPool::new(); in notify_all_single_thread_async()
|
| D | mu.rs | 1021 use futures_executor::{LocalPool, ThreadPool};
1080 let mut ex = LocalPool::new(); in async_smoke()
1234 let mut ex = LocalPool::new(); in single_thread_async()
1416 let mut ex = LocalPool::new(); in rw_single_thread_async()
|