|
@@ -142,7 +142,7 @@ class Pool(bootsteps.StartStopStep):
|
|
|
def create(self, w, semaphore=None, max_restarts=None):
|
|
|
threaded = not w.use_eventloop
|
|
|
procs = w.min_concurrency
|
|
|
- forking_enable = not threaded or (w.no_execv or not w.force_execv)
|
|
|
+ forking_enable = w.no_execv if w.force_execv else True
|
|
|
if not threaded:
|
|
|
semaphore = w.semaphore = LaxBoundedSemaphore(procs)
|
|
|
w._quick_acquire = w.semaphore.acquire
|