MadeLineProtoForHost/src/Pool.php at master · frankenstein-dr/MadeLineProtoForHost · GitHub

History

69 lines (59 loc) · 1.8 KB

Raw

<?php

if (!extension_loaded('pthreads')) {

class Pool

{

public function __construct($size, $class = \Worker::class, $ctor = [])

{

$this->size = $size;

$this->clazz = $class;

$this->ctor = $ctor;

}

public function submit(Threaded $collectable)

{

if ($this->last > $this->size) {

$this->last = 0;

}

if (!isset($this->workers[$this->last])) {

$this->workers[$this->last] =

new $this->clazz(...$this->ctor);

$this->workers[$this->last]->start();

}

$this->workers[$this->last++]->stack($collectable);

}

public function submitTo($worker, Threaded $collectable)

{

if (isset($this->workers[$worker])) {

$this->workers[$worker]->stack($collectable);

}

public function collect(Closure $collector = null)

{

$total = 0;

foreach ($this->workers as $worker) {

$total += $worker->collect($collector);

}

return $total;

}

public function resize($size)

{

if ($size < $this->size) {

while ($this->size > $size) {

if (isset($this->workers[$this->size - 1])) {

$this->workers[$this->size - 1]->shutdown();

}

unset($this->workers[$this->size - 1]);

$this->size--;

}

public function shutdown()

{

$this->workers = null;

}

protected $workers;

protected $size;

protected $last;

protected $clazz;

protected $ctor;

}

MadeLineProtoForHost/src/Pool.php at master · frankenstein-dr/MadeLineProtoForHost · GitHub

Expand file tree

Breadcrumbs

Pool.php

Latest commit

History

Breadcrumbs

Pool.php

File metadata and controls