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

simplify ThreadResult

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-14 16:03:17 -07:00
parent 1b7e6d1613
commit cd17da9f74
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 2 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
datastore/threads/threadresults.nim
View File

@ -23,7 +23,6 @@ type
## Encapsulates both the results from a thread but also the cross ## Encapsulates both the results from a thread but also the cross
## thread signaling mechanism. This makes it easier to keep them ## thread signaling mechanism. This makes it easier to keep them
## together. ## together.
sig*: SharedSignal
results*: Result[T, CatchableErrorBuffer] results*: Result[T, CatchableErrorBuffer]
TResult*[T] = SharedPtr[ThreadResult[T]] ##\ TResult*[T] = SharedPtr[ThreadResult[T]] ##\
@ -49,7 +48,7 @@ proc threadSafeType*[T: ThreadSafeTypes](tp: typedesc[T]) =
proc newThreadResult*[T]( proc newThreadResult*[T](
tp: typedesc[T] tp: typedesc[T]
): Future[TResult[T]] {.async.} = ): TResult[T] =
## Creates a new TResult including getting ## Creates a new TResult including getting
## a new ThreadSignalPtr from the pool. ## a new ThreadSignalPtr from the pool.
## ##
@ -57,25 +56,7 @@ proc newThreadResult*[T](
when not compiles(threadSafeType): when not compiles(threadSafeType):
{.error: "only thread safe types can be used".} {.error: "only thread safe types can be used".}
let res = newSharedPtr(ThreadResult[T]) return newSharedPtr(ThreadResult[T])
res[].sig = await SharedSignal.new()
res
proc `=destroy`*[T](res: var ThreadResult[T]) {.raises: [].} =
## release TResult and it's ThreadSignal
echoed "ThreadResult:destroy: ", res.addr.pointer.repr, " res: ", $(res)
res[].signal.release()
`=destroy`(res.results)
# proc release*[T](res: var TResult[T]) {.raises: [].} =
# ## release TResult and it's ThreadSignal
# # res[].signal.release()
# sharedptr.release(res)
template wait*[T](res: TResult[T]): Future[void] =
res[].sig.wait()
template fireSync*[T](res: TResult[T]): Result[bool, string] =
res[].sig.fireSync()
proc success*[T](ret: TResult[T], value: T) = proc success*[T](ret: TResult[T], value: T) =
## convenience wrapper for `TResult` to replicate ## convenience wrapper for `TResult` to replicate