Обновление с Pthreads v2 до v3: на что обратить внимание

Ниже приведен краткий пример использования встроенного сборщика мусора в pthreads:

 $worker = new Worker(); for ($i = 0; $i < 10; ++$i) { $worker->stack(new class extends Threaded {}); } $worker->start(); while ($worker->collect()); // blocks until all tasks have finished executing and have been collected $worker->shutdown(); 

Наконец, класс Stackable , ранее связанный с классом Threaded , был удален. Любые классы, которые расширили Stackable теперь должны быть изменены для расширения Threaded .

Удаленные Методы

Следующие методы были удалены:

• Threaded::getTerminatedInfo — из-за того, что сериализировать исключения небезопасно Встроенных альтернатив не существует, но поскольку PHP 7 преобразовал подавляющее большинство фатальных ошибок в исключения, вместо них можно использовать обработчики универсальных исключений:

   $task = new class extends Thread { public function run() { try { $this->task(); } catch (Throwable $ex) { // handle error here var_dump($ex->getMessage()); } } private function task() { $this->data = new Threaded(); $this->data = new StdClass(); // RuntimeException thrown var_dump(1); // never reached } }; $task->start() && $task->join(); 

  (См. Ниже о новом добавлении класса Volatile и впоследствии, почему приведенный выше код ошибочен.)

• Threaded::from — поскольку в PHP 7 есть анонимные классы, которые гораздо предпочтительнее использовать.

• Threaded::isWaiting — потому что он просто не нужен при синхронизации. Поток не должен задаваться вопросом, ожидает ли он чего-то, и, как таковой, нет альтернатив этому методу.

• Threaded::lock и его аналог Threaded::unlock — по тем же причинам классы Mutex и Cond были удалены. Учитывая, что синхронизация теперь синхронизирует таблицу свойств Threaded объектов, ее следует использовать вместо этого.

• Thread::kill — из-за того, что это не безопасно для выполнения. Альтернатив нет — код не должен просто убивать поток в такой высокоуровневой среде.

• Thread::detach — из-за того, что это не безопасно. Альтернатив нет — любой код, основанный на этом, необходимо будет переписать.

• Worker::isWorking — потому что в этом нет необходимости. Чтобы увидеть, остались ли у работника какие-либо задачи, следует использовать метод Worker::getStacked , который будет возвращать размер оставшегося стека.

Измененные Методы

Следующие методы были изменены:

• Worker::unstack — он больше не принимает параметр (который ранее удалял переданную задачу из стека). Это означает, что по умолчанию теперь просто удаляется только первая задача (самая старая) из стека, а не удаляются все задачи из стека.

• Pool::collect — теперь возвращает количество задач, которые нужно собрать, и колбэк-коллектор теперь необязательный. Если обратный вызов коллектора не используется, используется метод Worker::collector по умолчанию.

Новые классы

Класс Volatile был добавлен благодаря новой семантике неизменяемости классов Threaded , где, если у них есть свойства, являющиеся объектами Threaded , они являются неизменяемыми. Класс Volatile позволяет еще раз изменить код, который ранее зависел от изменчивости таких членов.

Например, следующий фрагмент кода работал бы на pthreads v2:

 class Task extends Threaded { public function __construct() { $this->data = new Threaded(); $this->data = new StdClass(); // previously ok, but not in pthreads v3 } } new Task(); 

Но теперь в pthreads v3 переназначение $this->data вызовет RuntimeException так как это свойство Threaded из класса Threaded . Чтобы правильно переназначить свойство, класс Task должен расширять Volatile :

 class Task extends Volatile { public function __construct() { $this->data = new Threaded(); $this->data = new StdClass(); } } new Task(); 

Массивы, назначаемые свойствам Threaded объектов, теперь автоматически приводятся к Volatile объектам, а не к Threaded объектам, поэтому их поведение остается в основном неизменным.

Хотя это новое ограничение неизменности немного увеличивает сложность, оно было введено для значительного увеличения производительности, которое оно дает при доступе к Threaded свойствам Threaded объектов.

Новые Методы

Были добавлены следующие методы:

• Worker::collect — это было введено для освобождения задач, завершившихся в стеке работника. Необязательная функция сборщика может быть передана, однако сборщик по умолчанию (из Worker::collector ) должен быть достаточным в подавляющем большинстве случаев.

  Например, следующее:

   $worker = new Worker(); var_dump(memory_get_usage()); // original memory usage for ($i = 0; $i < 500; ++$i) { $worker->stack(new class extends Threaded {}); } var_dump(memory_get_usage()); // memory usage after stacking 500 tasks $worker->start(); while ($worker->collect()); $worker->shutdown(); var_dump(memory_get_usage()); // memory usage after worker shutdown 

  Выходы:

   int(372912) int(486304) int(374528) 

  Со строкой, которая вызывает Worker::collect , использование памяти почти возвращается к норме. Без этого использование памяти не изменилось бы между 500 сложенными задачами и выключением рабочего. Хотя память в конечном итоге освободилась бы после уничтожения объекта, лучше явно освободить эту память (особенно для долго выполняющихся процессов, которым может потребоваться выполнить много задач). Поэтому всегда собирайте мусор, оставленный рабочими (а также бассейнами).

• Worker::collector — это было введено как реализация по умолчанию, используемая методом Worker::collect . Мы можем переопределить этот метод для случаев, когда мы хотим отложить сбор потраченных предметов. Как упомянуто выше, коллектор по умолчанию будет достаточным в подавляющем большинстве случаев, поэтому переопределите этот метод, только если вы знаете, что делаете!

• Threaded::notifyOne — это дополняет Threaded::notifyOne , позволяя отправлять сигнал только в один из ожидающих синхронизированных контекстов.

Вывод

В pthreads v3 был внесен ряд изменений, сделавших расширение более производительным и надежным. Некоторые вещи стали проще, особенно в отношении совместно используемых ресурсов, которые могут обрабатываться только через механизмы синхронизации ( Threaded::wait и Threaded::notify ). Другие вещи немного усложнились, особенно в отношении новых ограничений неизменности (в обмен на гораздо лучшую производительность). Но в целом, pthreads v3 получил хорошую очистку и выглядит все лучше.

Вы используете это? Пришлось обновляться с v2 до v3? Расскажите нам об этом — мы хотели бы написать о практическом примере обновления.