jyapayne/Nim
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fixes #1551

Browse source
This commit is contained in:
Araq 2014-10-11 12:25:15 +02:00
commit 6c9730b353
2 changed files with 8 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
lib/pure/concurrency/threadpool.nim
View file

@ -95,7 +95,7 @@ type
FlowVarBase* = ref FlowVarBaseObj ## untyped base class for 'FlowVar[T]'
FlowVarBaseObj = object of TObject
ready, usesCondVar: bool
ready, usesCondVar, awaited: bool
cv: CondVar #\
# for 'awaitAny' support
ai: ptr AwaitInfo
@ -129,8 +129,8 @@ type
proc await*(fv: FlowVarBase) =
## waits until the value for the flowVar arrives. Usually it is not necessary
## to call this explicitly.
if fv.usesCondVar:
fv.usesCondVar = false
if fv.usesCondVar and not fv.awaited:
fv.awaited = true
await(fv.cv)
destroyCondVar(fv.cv)