Searched refs:LocalSet (Results 1 – 6 of 6) sorted by relevance
11 use tokio::task::{self, LocalSet};21 LocalSet::new() in local_basic_scheduler()36 LocalSet::new() in local_threadpool()56 let local = LocalSet::new(); in localset_future_threadpool()68 let local = LocalSet::new(); in localset_future_timers()88 let local = LocalSet::new(); in localset_future_drives_all_local_futs()117 LocalSet::new() in local_threadpool_timer()145 LocalSet::new().block_on(&rt, async { in local_threadpool_blocking_in_place()164 LocalSet::new() in local_threadpool_blocking_run()193 LocalSet::new() in all_spawns_are_local()[all …]
937 let local = task::LocalSet::new();960 let local = task::LocalSet::new();
302 async_assert_fn!(tokio::task::LocalSet::run_until(_, BoxFutureSync<()>): !Send & !Sync);303 assert_value!(tokio::task::LocalSet: !Send & !Sync);
213 pub struct LocalSet {254 local_set: &'a LocalSet,323 impl LocalSet { implementation325 pub fn new() -> LocalSet { in new()326 LocalSet { in new()552 impl fmt::Debug for LocalSet { implementation558 impl Future for LocalSet { implementation582 impl Default for LocalSet { implementation583 fn default() -> LocalSet { in default()584 LocalSet::new() in default()[all …]
290 pub use local::{spawn_local, LocalSet};
103 - runtime: add link to `LocalSet` on `new_current_thread` ([#3508])173 - task: wake `LocalSet` on `spawn_local` ([#3369])184 - task: add `LocalSet` example ([#3438])640 - rt: `LocalSet` and task budgeting ([#2462]).711 - task: `LocalSet` was incorrectly marked as `Send` ([#2398])974 - `task::LocalSet.await` runs spawned tasks until the set is idle ([#1971]).1066 - `LocalSet::block_on` accepts `!'static` task ([#1882]).1074 - `LocalSet` drop inifinite loop ([#1892]).1075 - `LocalSet` hang under load ([#1905]).1103 - panic when dropping `LocalSet` ([#1843]).[all …]