mirror_php/parallel
1
0
Fork 0
mirror of https://github.com/amphp/parallel.git synced 2025-02-22 13:52:23 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Start global pool on creation

Browse Source
This commit is contained in:
Aaron Piotrowski 2017-12-08 10:31:28 -06:00
parent 5f8a382aa9
commit 4b8cb791c2
No known key found for this signature in database
GPG Key ID: ADD1EF783EDE9EEB
1 changed files with 16 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
lib/Worker/functions.php
View File

@ -9,7 +9,7 @@ const LOOP_POOL_IDENTIFIER = Pool::class;
const LOOP_FACTORY_IDENTIFIER = WorkerFactory::class; const LOOP_FACTORY_IDENTIFIER = WorkerFactory::class;
/** /**
* Returns the global worker pool for the current context. * Gets or sets the global worker pool. The pool is started if it is not already running.
* *
* @param \Amp\Parallel\Worker\Pool|null $pool A worker pool instance. * @param \Amp\Parallel\Worker\Pool|null $pool A worker pool instance.
* *
@ -25,6 +25,10 @@ function pool(Pool $pool = null): Pool {
$pool = new DefaultPool; $pool = new DefaultPool;
} }
if (!$pool->isRunning()) {
$pool->start();
}
Loop::setState(LOOP_POOL_IDENTIFIER, $pool); Loop::setState(LOOP_POOL_IDENTIFIER, $pool);
return $pool; return $pool;
} }
@ -37,17 +41,20 @@ function pool(Pool $pool = null): Pool {
* @return \Amp\Promise<mixed> * @return \Amp\Promise<mixed>
*/ */
function enqueue(Task $task): Promise { function enqueue(Task $task): Promise {
$pool = pool(); return pool()->enqueue($task);
if (!$pool->isRunning()) {
$pool->start();
}
return $pool->enqueue($task);
} }
/** /**
* Creates a worker using the global worker factory. * Gets a worker from the global worker pool.
*
* @return \Amp\Parallel\Worker\Worker
*/
function get(): Worker {
return pool()->get();
}
/**
* Creates a worker using the global worker factory. The worker is automatically started.
* *
* @return \Amp\Parallel\Worker\Worker * @return \Amp\Parallel\Worker\Worker
*/ */
@ -76,18 +83,3 @@ function factory(WorkerFactory $factory = null): WorkerFactory {
Loop::setState(LOOP_FACTORY_IDENTIFIER, $factory); Loop::setState(LOOP_FACTORY_IDENTIFIER, $factory);
return $factory; return $factory;
} }
/**
* Gets a worker from the global worker pool.
*
* @return \Amp\Parallel\Worker\Worker
*/
function get(): Worker {
$pool = pool();
if (!$pool->isRunning()) {
$pool->start();
}
return $pool->get();
}