fn sync() {
    std::thread::sleep(std::time::Duration::from_nanos(50));
    while executor::get_run_queue_len() > 0 {
        std::thread::sleep(std::time::Duration::from_nanos(50));
    }
}
// sync ensures message processing is complete before advancing
// There is a feedback loop, which has to complete before advancing
sync ensures message processing is complete before advancing
There is a feedback loop, which has to complete before advancing
sync ensures message processing is complete before advancing There is a feedback loop which has to complete before advancing
fn sync() {
    std::thread::sleep(std::time::Duration::from_nanos(50));
    while executor::get_run_queue_len() > 0 {
        std::thread::sleep(std::time::Duration::from_nanos(50));
    }
}
fn sync ( ) { std :: thread :: sleep ( std :: time :: Duration :: from_nanos ( 50 ) ) ; while executor :: get_run_queue_len ( ) > 0 { std :: thread :: sleep ( std :: time :: Duration :: from_nanos ( 50 ) ) ; } }
sync ensures message processing is complete before advancing
There is a feedback loop, which has to complete before advancing
sync ensures message processing is complete before advancing There is a feedback loop which has to complete before advancing