| use crate::loom::thread::AccessError; |
| use crate::runtime::coop; |
| |
| use std::cell::Cell; |
| |
| #[cfg(any(feature = "rt", feature = "macros"))] |
| use crate::util::rand::FastRand; |
| |
| cfg_rt! { |
| mod blocking; |
| pub(crate) use blocking::{disallow_block_in_place, try_enter_blocking_region, BlockingRegionGuard}; |
| |
| mod current; |
| pub(crate) use current::{with_current, try_set_current, SetCurrentGuard}; |
| |
| mod runtime; |
| pub(crate) use runtime::{EnterRuntime, enter_runtime}; |
| |
| mod scoped; |
| use scoped::Scoped; |
| |
| use crate::runtime::{scheduler, task::Id}; |
| |
| use std::task::Waker; |
| |
| cfg_taskdump! { |
| use crate::runtime::task::trace; |
| } |
| } |
| |
| cfg_rt_multi_thread! { |
| mod runtime_mt; |
| pub(crate) use runtime_mt::{current_enter_context, exit_runtime}; |
| } |
| |
| struct Context { |
| /// Uniquely identifies the current thread |
| #[cfg(feature = "rt")] |
| thread_id: Cell<Option<ThreadId>>, |
| |
| /// Handle to the runtime scheduler running on the current thread. |
| #[cfg(feature = "rt")] |
| current: current::HandleCell, |
| |
| /// Handle to the scheduler's internal "context" |
| #[cfg(feature = "rt")] |
| scheduler: Scoped<scheduler::Context>, |
| |
| #[cfg(feature = "rt")] |
| current_task_id: Cell<Option<Id>>, |
| |
| /// Tracks if the current thread is currently driving a runtime. |
| /// Note, that if this is set to "entered", the current scheduler |
| /// handle may not reference the runtime currently executing. This |
| /// is because other runtime handles may be set to current from |
| /// within a runtime. |
| #[cfg(feature = "rt")] |
| runtime: Cell<EnterRuntime>, |
| |
| #[cfg(any(feature = "rt", feature = "macros"))] |
| rng: Cell<Option<FastRand>>, |
| |
| /// Tracks the amount of "work" a task may still do before yielding back to |
| /// the sheduler |
| budget: Cell<coop::Budget>, |
| |
| #[cfg(all( |
| tokio_unstable, |
| tokio_taskdump, |
| feature = "rt", |
| target_os = "linux", |
| any(target_arch = "aarch64", target_arch = "x86", target_arch = "x86_64") |
| ))] |
| trace: trace::Context, |
| } |
| |
| tokio_thread_local! { |
| static CONTEXT: Context = const { |
| Context { |
| #[cfg(feature = "rt")] |
| thread_id: Cell::new(None), |
| |
| /// Tracks the current runtime handle to use when spawning, |
| /// accessing drivers, etc... |
| #[cfg(feature = "rt")] |
| current: current::HandleCell::new(), |
| |
| /// Tracks the current scheduler internal context |
| #[cfg(feature = "rt")] |
| scheduler: Scoped::new(), |
| |
| #[cfg(feature = "rt")] |
| current_task_id: Cell::new(None), |
| |
| /// Tracks if the current thread is currently driving a runtime. |
| /// Note, that if this is set to "entered", the current scheduler |
| /// handle may not reference the runtime currently executing. This |
| /// is because other runtime handles may be set to current from |
| /// within a runtime. |
| #[cfg(feature = "rt")] |
| runtime: Cell::new(EnterRuntime::NotEntered), |
| |
| #[cfg(any(feature = "rt", feature = "macros"))] |
| rng: Cell::new(None), |
| |
| budget: Cell::new(coop::Budget::unconstrained()), |
| |
| #[cfg(all( |
| tokio_unstable, |
| tokio_taskdump, |
| feature = "rt", |
| target_os = "linux", |
| any( |
| target_arch = "aarch64", |
| target_arch = "x86", |
| target_arch = "x86_64" |
| ) |
| ))] |
| trace: trace::Context::new(), |
| } |
| } |
| } |
| |
| #[cfg(any(feature = "macros", all(feature = "sync", feature = "rt")))] |
| pub(crate) fn thread_rng_n(n: u32) -> u32 { |
| CONTEXT.with(|ctx| { |
| let mut rng = ctx.rng.get().unwrap_or_else(FastRand::new); |
| let ret = rng.fastrand_n(n); |
| ctx.rng.set(Some(rng)); |
| ret |
| }) |
| } |
| |
| pub(super) fn budget<R>(f: impl FnOnce(&Cell<coop::Budget>) -> R) -> Result<R, AccessError> { |
| CONTEXT.try_with(|ctx| f(&ctx.budget)) |
| } |
| |
| cfg_rt! { |
| use crate::runtime::ThreadId; |
| |
| pub(crate) fn thread_id() -> Result<ThreadId, AccessError> { |
| CONTEXT.try_with(|ctx| { |
| match ctx.thread_id.get() { |
| Some(id) => id, |
| None => { |
| let id = ThreadId::next(); |
| ctx.thread_id.set(Some(id)); |
| id |
| } |
| } |
| }) |
| } |
| |
| pub(crate) fn set_current_task_id(id: Option<Id>) -> Option<Id> { |
| CONTEXT.try_with(|ctx| ctx.current_task_id.replace(id)).unwrap_or(None) |
| } |
| |
| pub(crate) fn current_task_id() -> Option<Id> { |
| CONTEXT.try_with(|ctx| ctx.current_task_id.get()).unwrap_or(None) |
| } |
| |
| #[track_caller] |
| pub(crate) fn defer(waker: &Waker) { |
| with_scheduler(|maybe_scheduler| { |
| if let Some(scheduler) = maybe_scheduler { |
| scheduler.defer(waker); |
| } else { |
| // Called from outside of the runtime, immediately wake the |
| // task. |
| waker.wake_by_ref(); |
| } |
| }); |
| } |
| |
| pub(super) fn set_scheduler<R>(v: &scheduler::Context, f: impl FnOnce() -> R) -> R { |
| CONTEXT.with(|c| c.scheduler.set(v, f)) |
| } |
| |
| #[track_caller] |
| pub(super) fn with_scheduler<R>(f: impl FnOnce(Option<&scheduler::Context>) -> R) -> R { |
| CONTEXT.with(|c| c.scheduler.with(f)) |
| } |
| |
| cfg_taskdump! { |
| /// SAFETY: Callers of this function must ensure that trace frames always |
| /// form a valid linked list. |
| pub(crate) unsafe fn with_trace<R>(f: impl FnOnce(&trace::Context) -> R) -> Option<R> { |
| CONTEXT.try_with(|c| f(&c.trace)).ok() |
| } |
| } |
| } |