Структура Builder

pub struct Builder<'a, T> { /* private fields */ }

Доступно только в tokio_unstable и с функцией crate rt и с функцией crate tracing.

Вариант task::Builder, который запускает задачи в JoinSet, а не в текущей среде выполнения по умолчанию.

Реализации

impl<'a, T: 'static> Builder<'a, T>

pub fn name(self, name: &'a str) -> Self

Назначает имя запускаемой задаче.

pub fn spawn<F>(self, future: F) -> Result<AbortHandle>
where F: Future<Output = T> + Send + 'static, T: Send,

Запускает указанную задачу с настройками этого построителя и сохраняет её в JoinSet, возвращая AbortHandle, который можно использовать для удалённой отмены задачи.

Возвращает

AbortHandle, который можно использовать для удалённой отмены задачи.

Паника

Этот метод вызывает панику, если его вызвать вне среды выполнения Tokio.

pub fn spawn_on<F>(self, future: F, handle: &Handle) -> Result<AbortHandle>
where F: Future<Output = T> + Send + 'static, T: Send,

Запускает указанную задачу с настройками этого построителя в указанной среде выполнения и сохраняет её в JoinSet.

Возвращает

AbortHandle, который можно использовать для удалённой отмены задачи.

pub fn spawn_blocking<F>(self, f: F) -> Result<AbortHandle>
where F: FnOnce() -> T + Send + 'static, T: Send,

Запускает блокирующий код в пуле потоков для блокирующих задач с настройками этого построителя и сохраняет его в JoinSet.

Возвращает

AbortHandle, который можно использовать для удалённой отмены задачи.

Паника

Этот метод вызывает панику, если его вызвать вне среды выполнения Tokio.

pub fn spawn_blocking_on<F>(self, f: F, handle: &Handle) -> Result<AbortHandle>
where F: FnOnce() -> T + Send + 'static, T: Send,

Запускает блокирующий код в пуле потоков для блокирующих задач указанной среды выполнения с настройками этого построителя и сохраняет его в JoinSet.

Возвращает

AbortHandle, который можно использовать для удалённой отмены задачи.

pub fn spawn_local<F>(self, future: F) -> Result<AbortHandle>
where F: Future<Output = T> + 'static,

Запускает указанную задачу в текущем LocalSet или LocalRuntime с настройками этого построителя и сохраняет её в JoinSet.

Возвращает

AbortHandle, который можно использовать для удалённой отмены задачи.

Паникает

Этот метод вызывает панику, если его вызвать вне LocalSet или LocalRuntime.

pub fn spawn_local_on<F>( self, future: F, local_set: &LocalSet, ) -> Result<AbortHandle>
where F: Future<Output = T> + 'static,

Запускает указанную задачу в предоставленном LocalSet с настройками этого построителя и сохраняет её в JoinSet.

Возвращает

AbortHandle, который можно использовать для удалённой отмены задачи.

Реализации трейтов

impl<'a, T> Debug for Builder<'a, T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Форматирует значение с помощью заданного форматтера. Подробнее

Автоматические реализации трейтов

impl<'a, T> !RefUnwindSafe for Builder<'a, T>

impl<'a, T> !UnwindSafe for Builder<'a, T>

impl<'a, T> Freeze for Builder<'a, T>

impl<'a, T> Send for Builder<'a, T>
where T: Send,

impl<'a, T> Sync for Builder<'a, T>
where T: Send,

impl<'a, T> Unpin for Builder<'a, T>

impl<'a, T> UnsafeUnpin for Builder<'a, T>

Обобщённые реализации

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Получает TypeId для self. Подробнее

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Неизменяемо заимствует данные из принадлежащего значения. Подробнее

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Изменяемо заимствует данные из принадлежащего значения. Подробнее

impl<T> From<T> for T

fn from(t: T) -> T

Возвращает аргумент без изменений.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Инструментирует этот тип с помощью предоставленного Span, возвращая обёртку Instrumented. Подробнее

fn in_current_span(self) -> Instrumented<Self> ⓘ

Инструментирует этот тип с помощью текущего Span, возвращая обёртку Instrumented. Подробнее

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Вызывает U::from(self).

То есть это преобразование выполняется так, как предписывает реализация From<T> for U.

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

Тип, возвращаемый в случае ошибки преобразования.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Выполняет преобразование.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

Тип, возвращаемый в случае ошибки преобразования.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Выполняет преобразование.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Присоединяет предоставленный Subscriber к этому типу и возвращает обёртку WithDispatch. Подробнее

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Присоединяет текущий по умолчанию Subscriber к этому типу и возвращает обёртку WithDispatch. Подробнее

MIT License
Copyright © Tokio Contributors
https://docs.rs/tokio/1.53.1/tokio/task/join_set/struct.Builder.html

спецификации, руководства, описания, API

free hit counter