fn decrypt_async(ciphertext: Vec<u8>, key: Vec<u8>) -> js_sys::Promise {
let (sender, receiver) = unbounded();
thread::spawn(move || {
let result = perform_decryption(&ciphertext, key.as_slice().try_into().unwrap()).unwrap();
let _ = sender.send(result);
});
future_to_promise(async move {
let result = receiver.recv().unwrap();
Ok(js_sys::Uint8Array::from(&result[..]).into())
})
.into()
}
Есть вот такая функция. perform_decryption это очень долгая операция.
Я хочу сделать так, что бы вызов этой функции из JS не блокировал основной поток, это можно сделать?
Дело в том, что по идее let result = receiver.recv().unwrap(); всё равно будет блокировать поток и ждать результата
В JS вызов выглядит так:
lib.decrypt_async(textBytes, key).then((res) => {
console.log("decrypted async: " + res);
});
Треды в браузерном WASM-е болезненные. Я даже не знаю можно ли коротко описать как правильно это сделать, я у себя несколько месяцев назад собирал поисковый код Tantivy в WASM и выносил всю поисковую нагрузку в отдельные веб-воркеры. Пришлось городить свои тред-пулы на веб-воркерах и sharedmemoryarray. Код можно посмотреть здесь: https://github.com/izihawa/summa/blob/master/summa-wasm/crate/worker_helper.rs, но будет тяжело.
Обсуждают сегодня