Структура Task Local Future
pub struct TaskLocalFuture<T, F>where
T: 'static,{ /* private fields */ }
Доступно только при включённой возможности crate
rt.Будущий объект, который во время выполнения задаёт значение T локального значения задачи для будущего объекта F.
Значение локальной переменной задачи должно быть 'static и будет удалено после завершения будущего объекта.
Создаётся функцией LocalKey::scope.
Примеры
tokio::task_local! {
static NUMBER: u32;
}
NUMBER.scope(1, async move {
println!("task local value: {}", NUMBER.get());
}).await;Реализации
impl<T, F> TaskLocalFuture<T, F>where T: 'static,
pub fn take_value(self: Pin<&mut Self>) -> Option<T>
Возвращает значение, сохранённое в локальной переменной задачи этим TaskLocalFuture.
Функция возвращает:
-
Some(T), если локальное значение задачи существует. -
None, если локальное значение задачи уже было извлечено.
Обратите внимание, что эта функция пытается извлечь локальное значение задачи, даже если выполнение будущего объекта ещё не завершено. В этом случае после вызова take_value значение больше не будет доступно через локальную переменную задачи.
Примеры
tokio::task_local! {
static KEY: u32;
}
let fut = KEY.scope(42, async {
// Do some async work
});
let mut pinned = Box::pin(fut);
// Complete the TaskLocalFuture
let _ = pinned.as_mut().await;
// And here, we can take task local value
let value = pinned.as_mut().take_value();
assert_eq!(value, Some(42));Реализации трейтов
impl<T, F> Debug for TaskLocalFuture<T, F>where T: Debug + 'static,
impl<T: 'static, F> Drop for TaskLocalFuture<T, F>
impl<T: 'static, F: Future> Future for TaskLocalFuture<T, F>
impl<'__pin, T, F> Unpin for TaskLocalFuture<T, F>where PinnedFieldsOf<__Origin<'__pin, T, F>>: Unpin, T: 'static,
Автоматические реализации трейтов
impl<T, F> !UnsafeUnpin for TaskLocalFuture<T, F>
impl<T, F> Freeze for TaskLocalFuture<T, F>
impl<T, F> RefUnwindSafe for TaskLocalFuture<T, F>where T: RefUnwindSafe, F: RefUnwindSafe,
impl<T, F> Send for TaskLocalFuture<T, F>
impl<T, F> Sync for TaskLocalFuture<T, F>
impl<T, F> UnwindSafe for TaskLocalFuture<T, F>where T: UnwindSafe, F: UnwindSafe,
Обобщённые реализации
impl<T> BorrowMut<T> for Twhere T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
Изменяемо заимствует данные из принадлежащего значения. Подробнее
impl<T> Instrument for T
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
impl<F> IntoFuture for Fwhere F: Future,
type Output = <F as Future>::Output
Результат, который будет получен при завершении будущего значения.
type IntoFuture = F
В какой тип будущего значения мы преобразуем это значение?
fn into_future(self) -> <F as IntoFuture>::IntoFuture
Создаёт будущее значение из значения. Подробнее
impl<T> WithSubscriber for T
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ
Присоединяет текущий по умолчанию
Subscriber к этому типу, возвращая обёртку WithDispatch. Подробнее
MIT License
Copyright © Tokio Contributors
https://docs.rs/tokio/1.53.1/tokio/task/futures/struct.TaskLocalFuture.html