diff options
| author | hozan23 <hozan23@karyontech.net> | 2024-06-27 02:39:31 +0200 |
|---|---|---|
| committer | hozan23 <hozan23@karyontech.net> | 2024-06-27 02:39:31 +0200 |
| commit | b8b5f00e9695f46ea30af3ce63aec6dd17f356ae (patch) | |
| tree | 3f1b07539c248f9536f5c7b6e3870e235d4f49d7 /core/src/async_util | |
| parent | 1a3ef2d77ab54bfe286f7400ac0cee2e25ea14e3 (diff) | |
Improve async channels error handling and replace unbounded channels with bounded channels
Remove all unbounded channels to prevent unbounded memory usage and
potential crashes.
Use `FuturesUnordered` for sending to multiple channels simultaneously.
This prevents the sending loop from blocking if one channel is blocked,
and helps handle errors properly.
Diffstat (limited to 'core/src/async_util')
| -rw-r--r-- | core/src/async_util/task_group.rs | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/core/src/async_util/task_group.rs b/core/src/async_util/task_group.rs index 63c1541..c55b9a1 100644 --- a/core/src/async_util/task_group.rs +++ b/core/src/async_util/task_group.rs @@ -87,6 +87,7 @@ impl TaskGroup { self.stop_signal.broadcast().await; loop { + // XXX BE CAREFUL HERE, it hold synchronous mutex across .await point. let task = self.tasks.lock().pop(); if let Some(t) = task { t.cancel().await |