AV
фьюча как раз и есть cooperative-мультитаскинг
Size: a a a
2020 September 13
AV
и если во фьючи запихивать очень жирный по ЦП кусок кода, то рантайм может встать колом
KB
Эх, опять перепутал, и правда наоборот)
AV
а корутины бывают разные в зависимости от языка )
AV
строго говоря, корутина - это всего лишь длинный паровоз кода, сцепленный yield/await.
KB
А футуры — то, что мы сцепляем?
AV
и это абстракция на уровне языка - preemptive или cooperative - уже особенность реализации компилятора/планировщика
AV
де факто футура = корутина
KB
Спасибо, гляну.
К
А как можно запускать async функции из коробки? Без использования futures
t
А как можно запускать async функции из коробки? Без использования futures
никак, нужен экзекутор
MB
А как можно запускать async функции из коробки? Без использования futures
А что эта функция делает?
Если она использует какие-то фичи рантайма (например spawn, сокеты и т.д.), то этот рантайм необходимо иметь.
Если она использует какие-то фичи рантайма (например spawn, сокеты и т.д.), то этот рантайм необходимо иметь.
MB
Если она ничем этим не пользуется, то сойдет максимально тупой "экзекутор" типа
fn block_on<F: Future> (mut fut: F) ->F::Output{
let waker = futures::future::null_waker();
futures::pin_mut!(fut);
loop {
if let Poll::Ready(out) = fut.poll(Context::from_waker(&waker)) {
return out;
}
}
}AV
А что эта функция делает?
Если она использует какие-то фичи рантайма (например spawn, сокеты и т.д.), то этот рантайм необходимо иметь.
Если она использует какие-то фичи рантайма (например spawn, сокеты и т.д.), то этот рантайм необходимо иметь.
бинго
MB
Если она ничем этим не пользуется, то сойдет максимально тупой "экзекутор" типа
fn block_on<F: Future> (mut fut: F) ->F::Output{
let waker = futures::future::null_waker();
futures::pin_mut!(fut);
loop {
if let Poll::Ready(out) = fut.poll(Context::from_waker(&waker)) {
return out;
}
}
}Но в таком случае есть еще более простое решение: не помечать эту функцию как async :)
AV
async - это вообще не про "много выполнять", а про "много ожидать" :)
A
2020 September 16
YM
доброго дня всем.
из доки
"Wait on multiple concurrent branches, returning when the first branch completes, cancelling the remaining branches"
> cancelling the remaining branches
как происходит cancelling, могу ли я перехватить cancelling в футуре к которой он применяется ?
из доки
tokio::select! :"Wait on multiple concurrent branches, returning when the first branch completes, cancelling the remaining branches"
> cancelling the remaining branches
как происходит cancelling, могу ли я перехватить cancelling в футуре к которой он применяется ?
r
доброго дня всем.
из доки
"Wait on multiple concurrent branches, returning when the first branch completes, cancelling the remaining branches"
> cancelling the remaining branches
как происходит cancelling, могу ли я перехватить cancelling в футуре к которой он применяется ?
из доки
tokio::select! :"Wait on multiple concurrent branches, returning when the first branch completes, cancelling the remaining branches"
> cancelling the remaining branches
как происходит cancelling, могу ли я перехватить cancelling в футуре к которой он применяется ?
Футура перестаёт поллиться и дропается. Перехватить дроп можно написав свою обёртку для футуры.