import x.executor

fn main() {
    mut ex := executor.new(queue_size: 4)!
    updates := chan string{cap: 1}

    ex.try_post(fn [updates] () ! {
        updates <- 'owner state updated'
    })!

    ran := ex.run_one()!
    if !ran {
        eprintln('executor did not run the queued job')
        exit(1)
    }

    println(<-updates)
    ex.stop()
    if ex.run_one()! {
        eprintln('unexpected job after stop')
        exit(1)
    }
    ex.wait()!
}