Привет,А может кто-то подсказать. Я делаю вот так,в надежде,что

Question

Привет,А может кто-то подсказать. Я делаю вот так,в надежде,что

он каждую транзакцию будет обрабатывать отдельно чтобы получить максимальную скорость.Но в итоге он обрабатывает пару минут и глохнет, почему такое может быть?
let stream = provider.subscribe_pending_txs().await.unwrap();
stream
.for_each_concurrent(None, |tx_hash| {
let provider_clone = provider.clone();
let pancake_factory = pancake_factory.clone();

async move {
let result = provider_clone.get_transaction(tx_hash).await;
let tx = match result {
Ok(x) => match x {
Some(x) => x,
None => return,
},
Err(x) => {
println!("{:?}", x);
return;
}
};
infra::process_tx(&tx, &provider_clone, &pancake_factory).await;
}
})
.await;

#backend #embedded #programming #russian #rust

0

05.10.2023

2 ответов

23 просмотра

Atlas Автор вопроса

Αλεχ Zhukovsky
если ты забиваешь треды которые вычитывают асинк з...

но у меня литерали 32 ядра, и каждая тарнзакция должна обрабатыавться не больше секунды-2

0

05.10.2023

Αλεχ Zhukovsky · Accepted Answer

если ты забиваешь треды которые вычитывают асинк задачи то у тебя оно будет застревать. spawn_blocking может помочь немного, но если у тебя задача дольше обрабатываются чем поступают то магии не произойдет и сообщения перестанут обрабатываться (среднее время обработки будет расти до бесконечности)

172 похожих чатов

Привет,А может кто-то подсказать. Я делаю вот так,в надежде,что

2 ответов

Похожие вопросы