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

minor improvement to the barrier implementation

Browse source
This commit is contained in:
Araq 2014-12-09 01:03:56 +01:00
commit 795a7762cc
3 changed files with 8 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -65,7 +65,9 @@ proc barrierEnter(b: ptr Barrier) {.compilerProc, inline.} =
proc barrierLeave(b: ptr Barrier) {.compilerProc, inline.} =
atomicInc b.left
when not defined(x86): fence()
if b.interest and b.left == b.entered: signal(b.cv)
# We may not have seen the final value of b.entered yet,
# so we need to check for >= instead of ==.
if b.interest and b.left >= b.entered: signal(b.cv)
proc openBarrier(b: ptr Barrier) {.compilerProc, inline.} =
b.entered = 0