ph
как-то так видимо (не проверял)
Size: a a a
2020 November 23
KR
как-то так видимо (не проверял)
+
AZ
impl Handler<Ping> for MyActor {
type Result = ResponseActFuture<Self, Result<bool, std::io::Error>>;
fn handle(&mut self, msg: Ping, ctx: &mut Context<Self>) -> Self::Result {
println!("Ping received");
let f = actix::fut::wrap_future::<_, Self>(async move {
connect("url").await;
Ok(true)
});
Box::pin(f)
}
}во, примерно это я и искал. спасибо
D
потёр срачик, давайте более конструктивно плз
АГ
impl Handler<Ping> for MyActor {
type Result = ResponseActFuture<Self, Result<bool, std::io::Error>>;
fn handle(&mut self, msg: Ping, ctx: &mut Context<Self>) -> Self::Result {
println!("Ping received");
let f = actix::fut::wrap_future::<_, Self>(async move {
connect("url").await;
Ok(true)
});
Box::pin(f)
}
}да, это работает. до тех пор, пока внутри не понадобится стейт актора. собственно в этом вся загвоздка, что внутри обычных футур актор недоступен. а внутри ActorFuture не работает await)
d
да, это работает. до тех пор, пока внутри не понадобится стейт актора. собственно в этом вся загвоздка, что внутри обычных футур актор недоступен. а внутри ActorFuture не работает await)
угу
d
делаем?
ph
да, это работает. до тех пор, пока внутри не понадобится стейт актора. собственно в этом вся загвоздка, что внутри обычных футур актор недоступен. а внутри ActorFuture не работает await)
через map можно закостылить 🤷♀️
d
через map можно закостылить 🤷♀️
ключевое слово "закостылить" 🙃
d
https://github.com/Diggsey/actix-interop
еще вот такой костыль есть, через thread-local
еще вот такой костыль есть, через thread-local
fixed
d
сразу говорю, пока не смотрел, я только что из под капота своей машины вылез, еле проблему нашёл, мне ща не до компа, я замёрз как не знаю кто, но я её починил
2020 November 24
A
Кто нить знает какой нить мануал как искать дедлоки?)
K
Кто нить знает какой нить мануал как искать дедлоки?)
gdb + thread apply all bt
AZ
gdb + thread apply all bt
помню как-то раз таким образом дебажил программу на 15к+ потоков :)
A
gdb + thread apply all bt
Геморойненько, с учетом того что для блокирущих тасков токио динамически создает треды
K
Геморойненько, с учетом того что для блокирущих тасков токио динамически создает треды
не уверен, но мне казалось что токио не создает треды динамически, не?
можно однотредовый рантайм заюзать
можно однотредовый рантайм заюзать
AZ
не уверен, но мне казалось что токио не создает треды динамически, не?
можно однотредовый рантайм заюзать
можно однотредовый рантайм заюзать
спавнит, если
spawn_blockingA
да я примерно знаю кусок - есть у меня канал для записи логов, если его сделать размером допустим "100" - все работает ок, но логи пишутся с большой задержкой, даже когда рантайм свободен - он с очередь канала никуя не пулит, начинает только если есть обращения по сети, если канал сделать размером "2" логи пытается писать сразу, и порой лочит как я понимаю воркера
A
не уверен, но мне казалось что токио не создает треды динамически, не?
можно однотредовый рантайм заюзать
можно однотредовый рантайм заюзать
мне не пойдет, динамически как отметили - у меня блоки через spwan_blocking запускаются