Class ApiGen\Scheduler\WorkerScheduler

`<TTask is Task, TResult>`

`abstract`
`implements`	`Scheduler<TTask, TResult>`

ApiGen\Scheduler\WorkerScheduler implements Scheduler<TTask, TResult>
- ApiGen\Scheduler\ForkScheduler
- ApiGen\Scheduler\ExecScheduler

Located at Scheduler/WorkerScheduler.php

Methods
`public`	`__construct(int $workerCount)` Overridden by `ApiGen\Scheduler\ForkScheduler::__construct()` `ApiGen\Scheduler\ExecScheduler::__construct()`	#
`public static`	`writeMessage(resource $stream, mixed $message): void`	#
`public static`	`readMessage(resource $stream): mixed`	#
`public static`	`workerLoop<T2 is Task, R2>(TaskHandler<T2, R2> $handler, resource $inputStream, resource $outputStream): void`	#
`public`	`schedule(TTask $task): void` Implements `ApiGen\Scheduler::schedule()`	#
`public`	`process(): iterable<TTask, TResult>` Implements `ApiGen\Scheduler::process()`	#
`abstract protected`	`start(): void` Implemented by `ApiGen\Scheduler\ForkScheduler::start()` `ApiGen\Scheduler\ExecScheduler::start()`	#
`abstract protected`	`stop(): void` Implemented by `ApiGen\Scheduler\ForkScheduler::stop()` `ApiGen\Scheduler\ExecScheduler::stop()`	#

Constants
`protected`		`WORKER_CAPACITY_LIMIT = 8`	#

Properties
`protected`	`SplQueue<TTask>`	`$tasks` queue of tasks which needs to be sent to workers queue of tasks which needs to be sent to workers	#
`protected`	`int`	`$pendingTaskCount = 0` total number of pending tasks (including those already sent to workers) total number of pending tasks (including those already sent to workers)	#
`protected`	`resource[]`	`$workerReadableStreams = []` indexed by [workerId] indexed by [workerId]	#
`protected`	`resource[]`	`$workerWritableStreams = []` indexed by [workerId] indexed by [workerId]	#
`protected`	`int`	`$workerCount`	#