Example for multi-threaded priority executor which doesn't run forever

[abique]

Hi,

I'm wondering how to implement a simple multi-threaded priority executor which doesn't live forever?

// This creates the threads as well, without using static variables
let ex = PriorityExecutor::new()?;

// do some work

// This will wait for all tasks to be completed and join the threads
drop(ex);

Thank you 👍

[notgull]

This will be a bit more complex then a typical example. The abstractions in this crate wouldn't be able to cut it. You would need to create a new executor, which:

• Has one heap/priority-queue per thread.
• Uses async_task crate to handle pushing tasks to these queues.
• Make this executor have an invariant lifetime tied to the tasks.

See this example for a starting point.