blob: 29759f3848c0bdc3c07e751c92c5e72f4ef41d33 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
use pthreads
func _assert_success(name:Text, val:Int32; inline)
fail("$name() failed!") if val < 0
struct ConnectionQueue(_connections:@[Int32]=@[], _mutex=pthread_mutex_t.new(), _cond=pthread_cond_t.new())
func enqueue(queue:ConnectionQueue, connection:Int32)
queue._mutex.lock()
queue._connections.insert(connection)
queue._mutex.unlock()
queue._cond.signal()
func dequeue(queue:ConnectionQueue -> Int32)
conn : Int32? = none
queue._mutex.lock()
while queue._connections.length == 0
queue._cond.wait(queue._mutex)
conn = queue._connections.pop(1)
queue._mutex.unlock()
queue._cond.signal()
return conn!
|
