KR
Нет. Он запустит футуру выполнятся на текущем потоке.
Send. В этом его смысл.Size: a a a
2021 May 24
KR
Т.е. не требует
F
т.е. он гарантирует, что конкретная
!Send футура будет выполняться только в этом потоке, но при этом и другие футуры тоже в нём могу запускаться?F
Окей, чуть расширю вопрос: мне нужно запустить
Это я правильно в сторону
!Send футуру из не-async функции так, чтоб она не блокировала текущий рантайм.Это я правильно в сторону
tokio::task::spawn_local смотрю, или ещё куда-то надо?F
Т.е. по факту нужен аналог
tokio::spawn на для !SendKR
Да
KR
Да, правильно.
KR
Это он и есть.
KR
Только твоя не-`async` функция должна запускать на одном из тредов токио-рантайма. Это, думаю, очевидно.
F
Ок, спасибо, продолжаю пробовать
MB
Если ты еще не прочитал документацию про LocalSet, то стоит прочтесть. spawn_local это маленькая обертка над ним.
F
Я читал, конечно. Не сразу всё в голове укладывается.
Вопрос выше пришлось решить с
т.е. без явного использования LocalSet в целом
Вопрос выше пришлось решить с
let runtime_handler = tokio::runtime::Handle::current();
thread::spawn(move || {
let maybe_server = cloned_self.server.lock();
runtime_handler.block_on(async {
server.stop(true).await;
let _ = tx.send(Ok(()));
})
});
т.е. без явного использования LocalSet в целом
MB
спавн отдельного треда это более дорогое решение, чем LocalSet, но тоже валидное.
F
Там проблема в том, что
А у меня вызывающая функция не-
spawn_local нужно запускать внутри LocalSet::run_until(), а он возвращает футуру, которую нужно эвейтить.А у меня вызывающая функция не-
async, так что только в отдельном треде, насколько я понимаюMB
Да, отдельный тред все равно придется запускать. Но с LocalSet ты сможешь на одном треде гонять много !Send-футур
MB
Хотя кстати есть вариант гонять LocalSet прямо в мейне
2021 May 27
KS
А есть какая-то возможность запустить async функцию из async главного треда так, чтобы она выполнялась параллельно основному?
K
что за "асинк главный тред"?
KS
Вот примерный код, в 40 строчке я хочу запустить параллельно прокси, который написан через async.