import x.executor

struct TextureUpload {
	id    int
	bytes int
}

fn main() {
	mut render := executor.new(queue_size: 8)!
	uploaded := chan TextureUpload{cap: 3}
	producer_done := chan bool{cap: 1}

	producer := spawn fn [mut render, producer_done, uploaded] () {
		for id in 0 .. 3 {
			bytes := 128 + id
			render.try_post(fn [uploaded, id, bytes] () ! {
				uploaded <- TextureUpload{
					id:    id
					bytes: bytes
				}
			}) or {
				producer_done <- false
				return
			}
		}
		producer_done <- true
	}()

	producer_ok := <-producer_done
	if !producer_ok {
		eprintln('producer could not submit render uploads')
		exit(1)
	}
	drained := render.drain_pending(8)!
	if drained != 3 {
		eprintln('expected 3 render uploads, got ${drained}')
		exit(1)
	}

	mut total_bytes := 0
	for _ in 0 .. 3 {
		total_bytes += (<-uploaded).bytes
	}
	println('uploaded ${drained} synthetic textures, bytes=${total_bytes}')

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