mirror of
https://github.com/codex-storage/nim-codex.git
synced 2025-02-12 21:07:02 +00:00
25 lines
740 B
Nim
25 lines
740 B
Nim
|
|
||
|
|
import pkg/taskpools
|
||
|
|
import pkg/taskpools/flowvars
|
||
|
|
import pkg/chronos
|
||
|
|
import pkg/chronos/threadsync
|
||
|
|
import pkg/questionable/results
|
||
|
|
|
||
|
|
const
|
||
|
|
CompletionRetryDelay* = 10.millis
|
||
|
|
CompletionTimeout* = 1.seconds # Maximum await time for completition after receiving a signal
|
||
|
|
|
||
|
|
proc awaitThreadResult*[T](signal: ThreadSignalPtr, handle: Flowvar[T]): Future[?!T] {.async.} =
|
||
|
|
await wait(signal)
|
||
|
|
|
||
|
|
var
|
||
|
|
res: T
|
||
|
|
awaitTotal: Duration
|
||
|
|
while awaitTotal < CompletionTimeout:
|
||
|
|
if handle.tryComplete(res):
|
||
|
|
return success(res)
|
||
|
|
else:
|
||
|
|
awaitTotal += CompletionRetryDelay
|
||
|
|
await sleepAsync(CompletionRetryDelay)
|
||
|
|
|
||
|
|
return failure("Task signaled finish but didn't return any result within " & $CompletionRetryDelay)
|