diff options
Diffstat (limited to 'examples/http-server/connection-queue.tm')
| -rw-r--r-- | examples/http-server/connection-queue.tm | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/examples/http-server/connection-queue.tm b/examples/http-server/connection-queue.tm index 3c8058d5..29759f38 100644 --- a/examples/http-server/connection-queue.tm +++ b/examples/http-server/connection-queue.tm @@ -1,22 +1,22 @@ use pthreads -func _assert_success(name:Text, val:Int32; inline): +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): +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): + func dequeue(queue:ConnectionQueue -> Int32) conn : Int32? = none queue._mutex.lock() - while queue._connections.length == 0: + while queue._connections.length == 0 queue._cond.wait(queue._mutex) conn = queue._connections.pop(1) |