sync: C.pthread_cond_t

[enghitalo]

fn main() {
	mut queue := new_queue[int]()

	// Start producer and consumer threads
	producer_thread := spawn producer(mut queue)
	consumer_thread := spawn consumer(mut queue)

	// Wait for threads to complete
	producer_thread.wait()
	consumer_thread.wait()

	// Clean up
	queue.destroy()
}

[spytheman]

Why not just use a channel?

[enghitalo]

Why not just use a channel?

How can I make the consumer always listen for changes on the channel?

Like here

fn consumer(mut queue ThreadSafeQueue[int]) {
// infinity for loop
	for {
		item := queue.dequeue()
		println('Consumed: ${item}')
	}
}

[enghitalo]

It is a better example

import time

fn producer(ch chan int) {
	for i in 1 .. 100 {
		ch <- i
		println('Produced: ${i}')
	}
}

fn consumer(ch chan int) {
	for {
		select {
			item := <-ch {
				println('Consumed: ${item}')
			}

			500 * time.millisecond {
				println('Timeout: No producers were ready within 0.5s')
				break
			}
		}
	}
}

fn main() {
	ch := chan int{cap: 10}

	producer_thread := spawn producer(ch)
	consumer_thread := spawn consumer(ch)

	producer_thread.wait()
	consumer_thread.wait()
}