mirror_php/parallel
1
0
Fork 0
mirror of https://github.com/amphp/parallel.git synced 2025-01-17 20:58:36 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Do not start global pool until used

Browse Source
This commit is contained in:
Aaron Piotrowski 2017-07-17 22:54:14 -05:00
parent ff146bc8ba
commit d4a2c311ca
No known key found for this signature in database
GPG Key ID: ADD1EF783EDE9EEB
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
lib/Worker/functions.php
View File

@ -25,10 +25,6 @@ function pool(Pool $pool = null): Pool {
$pool = new DefaultPool;
}
if (!$pool->isRunning()) {
$pool->start();
}
Loop::setState(LOOP_POOL_IDENTIFIER, $pool);
return $pool;
}
@ -41,7 +37,13 @@ function pool(Pool $pool = null): Pool {
* @return \Amp\Promise<mixed>
*/
function enqueue(Task $task): Promise {
return pool()->enqueue($task);
$pool = pool();
if (!$pool->isRunning()) {
$pool->start();
}
return $pool->enqueue($task);
}
/**
@ -81,5 +83,11 @@ function factory(WorkerFactory $factory = null): WorkerFactory {
* @return \Amp\Parallel\Worker\Worker
*/
function get(): Worker {
return pool()->get();
$pool = pool();
if (!$pool->isRunning()) {
$pool->start();
}
return $pool->get();
}