Структура LocalExecutor - Сводная таблица методов

Источник: Документация async-executor::LocalExecutor

Только один поток - нельзя передавать между потоками

Нет Send - задачи не должны быть Send

Локальное время жизни - привязан к области видимости

Блокирующие итераторы - могут заблокировать исполнитель

Сравнение с Executor

Характеристика	LocalExecutor	Executor
Многопоточность	❌ Только один поток	✅ Многопоточный
Требование Send	❌ Не требуется	✅ Обязательно
Производительность	✅ Выше для локальных задач	✅ Лучше для CPU-bound
Безопасность	✅ Нет гонок данных	✅ Синхронизированный

Основные методы

Метод	Сигнатура	Возвращаемый тип	Описание	Особенности
`new`	`pub const fn new() -> LocalExecutor<'a>`	`LocalExecutor<'a>`	Создает однопоточный исполнитель	Только для текущего потока
`is_empty`	`pub fn is_empty(&self) -> bool`	`bool`	Проверяет отсутствие незавершенных задач	`true` если задач нет
`spawn`	`pub fn spawn<T>(future: impl Future<Output = T> + 'a) -> Task<T>`	`Task<T>`	Запускает задачу в исполнителе	Не требует `Send`
`spawn_many`	`pub fn spawn_many<T, F>(futures: impl IntoIterator<Item = F>, handles: &mut impl Extend<Task<F::Output>>)`	`()`	Массовый запуск задач	Улучшает производительность
`try_tick`	`pub fn try_tick(&self) -> bool`	`bool`	Пытается выполнить одну задачу	Неблокирующий
`tick`	`pub async fn tick(&self)`	`()`	Выполняет одну задачу	Блокирует если задач нет
`run`	`pub async fn run<T>(future: impl Future<Output = T>) -> T`	`T`	Запускает исполнитель до завершения фьючерса	Основной метод выполнения

Подробное описание методов

Конструкторы

Метод	Особенности	Пример использования
`new`	Создает локальный исполнитель для текущего потока	`let ex = LocalExecutor::new();`
`default`	Через трейт Default (аналогично new)	`let ex = LocalExecutor::default();`

Управление задачами

Метод	Назначение	Отличие от Executor
`spawn`	Запуск одной задачи	Не требует `Send`
`spawn_many`	Пакетный запуск задач	Блокировка не снимается (нет других потоков)
`is_empty`	Проверка состояния	Аналогично Executor

Выполнение

Метод	Тип выполнения	Применение
`try_tick`	Неблокирующий	Для фонового выполнения
`tick`	Асинхронный	Для кооперативной многозадачности
`run`	Блокирующий	Основной цикл выполнения

Требования к типам

Для задач

Параметр	Требование	Обоснование
`T`	`'a`	Время жизни задачи
`F`	`Future<Output = T> + 'a`	Локальный фьючерс
Отсутствует	`Send`	Только один поток

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

Стандартные трейты

Трейт	Назначение	Особенности
`Debug`	Отладочный вывод	Форматирование
`Default`	Значение по умолчанию	Аналогично `new()`

Маркерные трейты (отличия от Executor)

Трейт	Реализация	Обоснование
`!Send`	Не реализован	Только для текущего потока
`!Sync`	Не реализован	Нельзя разделять между потоками
`UnwindSafe`	Реализован	Безопасность при панике
`RefUnwindSafe`	Реализован	Безопасность ссылок при панике

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

Трейт	Статус	Примечание
`Unpin`	Реализован	Можно перемещать
`!Freeze`	Не замораживается	-

Примеры использования

Базовое использование

#![allow(unused)]
fn main() {
use async_executor::LocalExecutor;
use futures_lite::future;

let local_ex = LocalExecutor::new();

future::block_on(local_ex.run(async {
    println!("Hello world!");
}));
}

Запуск задач

#![allow(unused)]
fn main() {
let ex = LocalExecutor::new();

// Одиночная задача
let task = ex.spawn(async { 1 + 2 });

// Массовый запуск
let mut tasks = vec![];
ex.spawn_many([async { 1 }, async { 2 }], &mut tasks);
}

Keyboard shortcuts

DOCS.RS