import x.executor

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

    runner := spawn fn [mut ex, run_result] () {
        ex.run() or {
            run_result <- err.msg()
            return
        }
        run_result <- 'ok'
    }()

    caller := spawn fn [mut ex, result] () {
        ex.run_sync(fn [result] () ! {
            result <- 'ran on owner loop'
        }) or { result <- 'run_sync failed: ${err.msg()}' }
    }()

    msg := <-result
    if msg != 'ran on owner loop' {
        eprintln(msg)
        exit(1)
    }
    println(msg)

    ex.stop()
    run_msg := <-run_result
    if run_msg != 'ok' {
        eprintln('run failed: ${run_msg}')
        exit(1)
    }
    ex.wait()!
    caller.wait()
    runner.wait()
}