Struct pr47::util::serializer::CoroutineSharedData

pub struct CoroutineSharedData { /* fields omitted */ }

Context shared by all coroutines in the same serialization group

Implementations

impl CoroutineSharedData

pub fn new() -> Self

Creates a new SharedContext.

pub fn add_task(&mut self, rx: Receiver<()>) -> u32

Add a new task to context, saving the “completion signal receiver” to the context, returning the allocated task ID.

The allocated task ID starts from 1 instead of 0, since the main task is not managed by SharedContext.

pub fn remove_task(&mut self, task_id: u32)

Remove the given task from context, together with its “completion signal receiver”. This is called on child task exit, in order to reduce the burden of main task.

pub fn retrieve_all_tasks(&mut self) -> HashMap<u32, Receiver<()>>

Retrieve all tasks and their “completion signal receiver”, cleaning internal storage of SharedContext. This is used by main task to await for all running child tasks.