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

make threadpool care about minPoolSize

Browse source
This commit is contained in:
Andreas Rumpf 2017-10-12 12:45:18 +02:00
commit 8a2f481f99
1 changed files with 10 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -448,12 +448,22 @@ proc nimSpawn3(fn: WorkerProc; data: pointer) {.compilerProc.} =
if selectWorker(readyWorker, fn, data): return if selectWorker(readyWorker, fn, data): return
for i in 0.. <currentPoolSize: for i in 0.. <currentPoolSize:
if selectWorker(addr(workersData[i]), fn, data): return if selectWorker(addr(workersData[i]), fn, data): return
# determine what to do, but keep in mind this is expensive too: # determine what to do, but keep in mind this is expensive too:
# state.calls < maxPoolSize: warmup phase # state.calls < maxPoolSize: warmup phase
# (state.calls and 127) == 0: periodic check # (state.calls and 127) == 0: periodic check
if state.calls < maxPoolSize or (state.calls and 127) == 0: if state.calls < maxPoolSize or (state.calls and 127) == 0:
# ensure the call to 'advice' is atomic: # ensure the call to 'advice' is atomic:
if tryAcquire(stateLock): if tryAcquire(stateLock):
if currentPoolSize < minPoolSize:
if not workersData[currentPoolSize].initialized:
activateWorkerThread(currentPoolSize)
let w = addr(workersData[currentPoolSize])
atomicInc currentPoolSize
if selectWorker(w, fn, data):
release(stateLock)
return
case advice(state) case advice(state)
of doNothing: discard of doNothing: discard
of doCreateThread: of doCreateThread: