logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-05 06:23:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix decrement and free in channel

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-09 21:18:21 -07:00
parent a2b74aeb33
commit 94c9ad01f6
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/apatheia/queues.nim
View File

@ -1,4 +1,4 @@
import std/options
import ./types
import chronos
@ -6,6 +6,7 @@ import results
import chronos/threadsync
export types
export options
type
ChanPtr[T] = ptr Channel[T]
@ -24,5 +25,19 @@ proc new*[T](tp: typedesc[AsyncQueue[T]]): AsyncQueue[T] {.raises: [ApatheiaSign
raise newException(ApatheiaSignalErr, msg: res.err())
result.signal = res.get()
result.chan = allocSharedChannel()
proc send*[T](c: AsyncQueue[T], msg: sink T) {.inline.} =
## Sends a message to a thread. `msg` is copied.
c.chan.send(msg)
proc trySend*[T](c: AsyncQueue[T], msg: sink T): bool {.inline.} =
c.chan.trySend(msg)
proc recv*[T](c: AsyncQueue[T]): T =
c.chan.recv()
proc tryRecv*[T](c: AsyncQueue[T]): Option[T] =
let res = c.chan.recv()
if res.dataAvailable:
some res.msg