mirror of
https://github.com/logos-storage/apatheia.git
synced 2026-01-03 21:43:08 +00:00
rename queue
This commit is contained in:
parent
fb3a50e0e7
commit
be9b236c06
@ -22,6 +22,10 @@ type
|
||||
signal: ThreadSignalPtr
|
||||
chan*: ChanPtr[T]
|
||||
|
||||
proc destroy*[T](val: SignalQueue[T]) =
|
||||
deallocShared(val.chan)
|
||||
discard val.signal.close()
|
||||
|
||||
proc newSignalQueue*[T](maxItems: int = 0): SignalQueue[T] {.raises: [ApatheiaSignalErr].} =
|
||||
let res = ThreadSignalPtr.new()
|
||||
if res.isErr():
|
||||
|
||||
@ -1,3 +1,4 @@
|
||||
switch("path", "$projectDir/../src")
|
||||
|
||||
--threads:on
|
||||
--mm:refc
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user