v_windows/v/vlib/sync/channel_fill_test.v


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

import sync

const (
	queue_len  = 1000
	queue_fill = 763
)

fn do_send(ch chan int, mut fin sync.Semaphore) {
	for i in 0 .. queue_fill {
		ch <- i
	}
	fin.post()
}

fn test_channel_len_cap() {
	ch := chan int{cap: queue_len}
	mut sem := sync.new_semaphore()
	go do_send(ch, mut sem)
	sem.wait()
	assert ch.cap == queue_len
	assert ch.len == queue_fill
}