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

fixes #10584 [backport]

Browse source
This commit is contained in:
Andreas Rumpf 2019-02-06 20:58:21 +01:00
commit 65f3e390e8
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -320,6 +320,10 @@ gSomeReady.initSemaphore()
proc slave(w: ptr Worker) {.thread.} = proc slave(w: ptr Worker) {.thread.} =
isSlave = true isSlave = true
while true: while true:
if w.shutdown:
w.shutdown = false
atomicDec currentPoolSize
break
when declared(atomicStoreN): when declared(atomicStoreN):
atomicStoreN(addr(w.ready), true, ATOMIC_SEQ_CST) atomicStoreN(addr(w.ready), true, ATOMIC_SEQ_CST)
else: else:
@ -340,9 +344,6 @@ proc slave(w: ptr Worker) {.thread.} =
dec numSlavesRunning dec numSlavesRunning
if w.q.len != 0: w.cleanFlowVars if w.q.len != 0: w.cleanFlowVars
if w.shutdown:
w.shutdown = false
atomicDec currentPoolSize
proc distinguishedSlave(w: ptr Worker) {.thread.} = proc distinguishedSlave(w: ptr Worker) {.thread.} =
while true: while true: