массивы — PHP многопоточный код Pthread медленнее, чем один поток

Ваш код просто невероятно неэффективен. Есть также ряд проблем с этим — я кратко остановился на некоторых из этих вещей ниже.

Во-первых, вы раскручиваете более 500 потоков (9 * 56 = 504). Это будет очень медленно, потому что многопоточность в PHP требует архитектуры без общего доступа. Это означает, что новый экземпляр интерпретатора PHP необходимо будет создавать для каждого создаваемого вами потока, где все классы, интерфейсы, признаки, функции и т. Д. Необходимо будет скопировать в новый экземпляр интерпретатора.

Возможно, еще важнее то, что ваши 3 вложенные for петли выполняют 54 миллиона итерации (90 * 200 * 3000). Умножьте это на 504 создаваемых потока, и вы скоро увидите, почему все становится вялым. Вместо этого используйте пул потоков (см. Pthreads ‘ Pool класс) с более скромным количеством потоков (попробуйте 8 и переходите оттуда) и сократите количество итераций, выполняемых для каждого потока.

Во-вторых, вы открываете файл 90 раз за поток (итого 90 * 504 = 45360). Вам нужен только один обработчик файлов на поток.

В-третьих, использование реальных массивов PHP внутри Threaded объекты делают их только для чтения. Так что в отношении $this->c2_result свойство, код внутри вашего вложенного while петля не должна даже работать. Не говоря уже о том, что следующая проверка не ищет дубликаты:

if(count(array_flip($this->c2_result)) != count($this->c2_result))

Если вы избегаете кастинга $this->c2_result свойство массива (поэтому делает его Volatile объект), тогда следующий код может вместо этого заменить while цикл:

$keys = array_rand($this->linesId, 7);
for ($i = 0; $i < 7; ++$i) {
$this->c2_result[$this->linesId[$keys[$i]]] = true;
}

Установив значения в качестве ключей в $this->c2_result мы можем удалить последующее in_array вызов функции для поиска через $this->c2_result, Это делается путем использования массива PHP в качестве хеш-таблицы, где время поиска ключа является постоянным временем (O (1)), а не линейным временем, требуемым при поиске значений (с in_array). Это позволяет нам заменить следующую медленную проверку:

if(!in_array($this->linesId2[$this->traceId],$this->c2_result))

со следующей быстрой проверкой:

if (!isset($this->c2_result[$this->linesId2[$this->traceId]]))

Но с учетом сказанного вы, кажется, не используете $this->c2_result недвижимость в другом месте. Таким образом (при условии, что у вас нет преднамеренно отредактированного кода, который его использует), вы можете полностью удалить его и просто заменить цикл while при проверке после него следующим:

$found = false;

foreach (array_rand($this->linesId, 7) as $key) {
if ($this->linesId[$key] === $this->linesId2[$this->traceId]) {
$found = true;
break;
}
}

if (!$found) {
++$b;
}

Помимо вышесказанного, вы также можете посмотреть на хранение данных, которые вы собираете в памяти (как некоторые свойства на Threaded объект), чтобы предотвратить дорогие записи на диск. Результаты могут быть агрегированы в конце, до закрытия пула.

Обновление на основе вашего обновления

Вы сказали, что rand функция вызывает значительное замедление. Хотя это может быть частью проблемы, я считаю, что это на самом деле весь код внутри вашего третьего вложенного for петля. Код внутри есть очень горячий код, потому что он выполняется 54 миллиона раз. Выше я предложил заменить следующий код:

$zex=0;

while($zex != 1) {
$c2_result[0]=$lines[rand(0,324631)];
$c2_result[1]=$lines[rand(0,324631)];
$c2_result[2]=$lines[rand(0,324631)];
$c2_result[3]=$lines[rand(0,324631)];
$c2_result[4]=$lines[rand(0,324631)];
$c2_result[5]=$lines[rand(0,324631)];
$c2_result[6]=$lines[rand(0,324631)];

$myArray = (array) $c2_result;
$myArray2 = (array) $c2_result;
$myArray=array_flip($myArray);

if(count($myArray) != count($c2_result)) {//echo "duplicates\n";
$zex=0;
} else {//echo "no duplicates\n";
$zex=1;
//exit;
}
}

if(!in_array($lines2[$this->traceId],$myArray2)) {
$b++;
}

с сочетанием array_rand а также foreach, После некоторых первоначальных испытаний выясняется, что array_rand на самом деле превосходно медленный. Но мое решение хэш-таблицы, чтобы заменить in_array вызов по-прежнему остается в силе. Используя массив PHP как хеш-таблицу (в основном, сохраняя значения в виде ключей), мы получаем постоянную производительность поиска по времени (O (1)), в отличие от линейного поиска по времени (O (n)).

Попробуйте заменить приведенный выше код следующим:

$myArray = [];

$myArray[rand(0,324631)] = true;
$myArray[rand(0,324631)] = true;
$myArray[rand(0,324631)] = true;
$myArray[rand(0,324631)] = true;
$myArray[rand(0,324631)] = true;
$myArray[rand(0,324631)] = true;
$myArray[rand(0,324631)] = true;

while (count($myArray) !== 7) {
$myArray[rand(0,324631)] = true;
}

if (!isset($myArray[$lines2[$this->traceId]])) {
$b++;
}

Для меня это привело к ускорению на 120%.

Что касается дальнейшей производительности, вы можете (как уже упоминалось выше, снова) сохранить результаты в памяти (как простое свойство) и выполнить запись всех результатов в конце run метод.

Кроме того, сборщик мусора для pthreads не является детерминированным. Поэтому его не следует использовать для извлечения данных. Вместо этого Threaded объект должен быть введен в рабочий поток, где данные, которые будут собраны, должны быть сохранены в этот объект. Наконец, вы должны закрыть бассейн после сборщик мусора (который, опять же, не должен использоваться в вашем случае).