Searched refs:new_current_thread (Results 1 – 25 of 26) sorted by relevance
12
58 let rt = Builder::new_current_thread().build().unwrap(); in test_abort_without_panic_3662()131 let rt = Builder::new_current_thread().build().unwrap(); in remote_abort_local_set_3929()153 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_wakes_task_3964()185 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_task_that_panics_on_drop_contained()210 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_task_that_panics_on_drop_returned()
95 let rt = runtime::Builder::new_current_thread().build().unwrap(); in no_block_in_basic_block_on()107 let inner = tokio::runtime::Builder::new_current_thread() in can_enter_basic_rt_from_within_block_in_place()125 let _ = tokio::runtime::Builder::new_current_thread() in useful_panic_message_when_dropping_rt_in_rt()147 let rt = tokio::runtime::Builder::new_current_thread() in can_shutdown_with_zero_timeout_in_runtime()159 let rt = tokio::runtime::Builder::new_current_thread() in can_shutdown_now_in_runtime()
49 let rt = runtime::Builder::new_current_thread() in get_or_init()74 let rt = runtime::Builder::new_current_thread() in get_or_init_panic()99 let rt = runtime::Builder::new_current_thread() in set_and_get()132 let rt = runtime::Builder::new_current_thread() in set_while_initializing()157 let rt = runtime::Builder::new_current_thread() in get_or_try_init()
48 let rt = runtime::Builder::new_current_thread() in test_drop_on_notify()93 let rt = runtime::Builder::new_current_thread().build().unwrap(); in panics_when_io_disabled()
56 tokio::runtime::Builder::new_current_thread()486 fn new_current_thread() -> Runtime { in new_current_thread() function487 tokio::runtime::Builder::new_current_thread() in new_current_thread()501 let rt = new_current_thread(); in test_with_runtimes()
176 let rt = tokio::runtime::Builder::new_current_thread() in timeout_panics_when_no_time_handle()187 tokio::runtime::Builder::new_current_thread() in rt()
40 tokio::runtime::Builder::new_current_thread() in rt()
50 tokio::runtime::Builder::new_current_thread() in rt()
50 runtime::Builder::new_current_thread() in rt()
31 let rt = Builder::new_current_thread().enable_all().build().unwrap(); in timer_with_basic_scheduler()
141 let rt = runtime::Builder::new_current_thread() in local_threadpool_blocking_in_place()521 tokio::runtime::Builder::new_current_thread() in rt()
471 tokio::runtime::Builder::new_current_thread() in rt()
13 tokio::runtime::Builder::new_current_thread()
11 let rt = Builder::new_current_thread().enable_time().build().unwrap();19 let rt = Builder::new_current_thread().enable_time().build().unwrap();
52 let rt1 = Arc::new(Builder::new_current_thread().build().unwrap()); in block_on_num_polls()70 let rt = Builder::new_current_thread().build().unwrap(); in assert_no_unnecessary_polls()
18 let rt = Builder::new_current_thread().build().unwrap(); in wake_during_shutdown()
143 CombiRuntime::CurrentThread => Builder::new_current_thread().build().unwrap(), in test_combination()
30 let rt = runtime::Builder::new_current_thread() in block_on()
186 crate::runtime::Builder::new_current_thread() in test_splitter()202 crate::runtime::Builder::new_current_thread() in test_pseudo_text()
149 crate::runtime::Builder::new_current_thread() in rt()
259 runtime::Builder::new_current_thread() in rt()
676 let runtime = tokio::runtime::Builder::new_current_thread() in decode_tokio_02()712 let runtime = tokio::runtime::Builder::new_current_thread() in decode_tokio_03()748 let runtime = tokio::runtime::Builder::new_current_thread() in decode_tokio()
100 pub fn new_current_thread() -> Builder { in new_current_thread() method
318 tokio::runtime::Builder::new_current_thread() in parse_knobs()
479 Builder::new_current_thread().build()?.block_on(UwbAdaptationImpl::new(rsp_sender))?, in new()