import x.executor

fn main() {
    mut ex := executor.new(queue_size: 8)!
    events := chan int{cap: 6}

    for i in 0 .. 6 {
        ex.try_post(fn [events, i] () ! {
            events <- i
        })!
    }

    mut frame := 0
    mut drained_total := 0
    for drained_total < 6 {
        frame++
        drained := ex.drain_pending(2)!
        if drained == 0 {
            eprintln('frame ${frame} did not drain any work')
            exit(1)
        }
        drained_total += drained
        println('frame ${frame}: drained ${drained} owner jobs')
    }

    mut checksum := 0
    for _ in 0 .. 6 {
        checksum += <-events
    }
    println('checksum=${checksum}')

    ex.stop()
    if ex.drain_pending(1)! != 0 {
        eprintln('unexpected job after stop')
        exit(1)
    }
    ex.wait()!
}