Icicle\Concurrent
This optional package provides native threading, multiprocessing, process synchronization, shared memory, and task workers. The package is available on Packagist as icicleio/concurrent
.
Worker\pool()
Worker\pool(Pool $pool = null): Pool
Returns the global worker pool for the current context.
Parameters
$pool
- A worker pool instance.
Return value
The global worker pool instance.
Worker\enqueue()
Worker\enqueue(Task $task): \Generator
Enqueues a task to be executed by the global worker pool.
Parameters
Task $task
- The task to enqueue.
Return value
Generator that resolves with the task return value.
Worker\create()
Worker\create(): Worker
Creates a worker using the global worker factory.
Worker\factory()
Worker\factory(WorkerFactory $factory = null): WorkerFactory
Gets or sets the global worker factory.
Worker\get()
Worker\get(): Worker
Gets a worker from the global worker pool.
Next: Context