многопоточность — «прогулка» массив PHP, использующий многопоточный (асинхронный) с хаком (HHVM)

Не уверен, почему до сих пор нет тега «взломать» (извините за список в PHP), но …

Мне интересно, возможно ли это / как можно обойти массив, используя несколько потоков, используя многопоточную / асинхронную функцию hack. Мне это действительно не нужно, но это любопытство и может быть полезным.

Я посмотрел документацию по асинхронной функции «Hack»

http://docs.hhvm.com/manual/en/hack.async.php

и это немного сложно.

Вот основная идея того, что я хотел бы сделать (или посмотреть готово):

а) разбить массив на х разделов и обработать его на х «потоки» или б) создать х потоков, и каждый обрабатывает последний доступный элемент, т.е. когда поток обрабатывает элемент, он запрашивает у родительского потока новый для обработки. Hack не делает «потоки», но то же самое представлено функцией asyc

По сути, конечная цель — быстро оптимизировать стандартный блок foreach для работы в нескольких потоках, поэтому требуется минимальное изменение кода, а также узнать, что может сделать хак и как он работает.

В качестве примера я придумал некоторый код, но думаю, что совершенно не понял эту идею.

class ArrayWalkAsync
{
protected $array;
protected $threads = Array();
protected $current_index = 0;
protected $max_index;
protected $threads = 4;

public function array_walk($array)
{
$this->array = $array;
$this->max_index = count($array) - 1;
$result = Array();
for ($i=0;$i<$this->threads;$i++)
{
$this->threads[] = new ArrayWalkThread();
}
$continue = true;
while($continue)
{
$awaitables = Array();
for ($i=0;$i<$this->threads;$i++)
{
$a = $this->proccesNextItem($i);
if ($a)
{
$this->threads[] = $a;
} else {
$continue = false;
}
}
// wait for each
foreach ($awaitables as $awaitable_i)
{
await awaitable_i;
// do something with the result
}
}
}

protected function proccesNextItem($thread_id)
{
if ($this->current_index > $this->max_index)
{
return false;
}
$a = new ArrayWalkItem();
$a->value = $this->array[$this->current_index];
$a->index = $this->current_index;
$this->current_index++;
return $this->threads[$thread_id]->process($a,$this);
}

public function processArrayItem($item)
{
$value = $item->value;
sleep(1);
$item->result = 1;
}

}


class ArrayWalkThread
{
async function process($value,$parent): Awaitable<?ArrayWalkItem>
{
$parent->processArrayItem($a);
}

}

class ArrayWalkItem
{
public $value;
public $result;
}