在PHP CLI中使用并行线程运行大循环
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了在PHP CLI中使用并行线程运行大循环，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1862字，纯文字阅读大概需要3分钟。
内容图文
我在Symfony2 / PHP中有一个计算昂贵的后端进程,我想运行多线程.
由于我迭代了数千个对象,我想我不应该为每个对象启动一个线程.我想有一个$cores变量来定义我想并行的线程数,然后遍历循环并保持运行的那么多线程.因此,每次线程完成时,应启动具有下一个对象的新线程,直到完成所有对象.
查看pthreads文档并进行一些Google搜索,我找不到这种情况的可用示例.我发现的所有示例都有一次固定数量的线程,它们都没有遍历数千个对象.
有人能指出我正确的方向开始吗？我理解设置线程和加入它等的基础知识,但不了解如何在具有等待条件的循环中执行此操作.
解决方法:
这个问题的答案是使用Pool和Worker抽象.
基本的想法是你::将Threaded对象提交给Pool,它将它堆叠到下一个可用的Worker上,在所有Worker上分发你的Threaded对象(循环法).
以下是PHP7的超简单代码(pthreads v3)：
<?php
$jobs = [];
while (count($jobs) < 2000) {
$jobs[] = mt_rand(0, 1999);
}
$pool = new Pool(8);
foreach ($jobs as $job) {
$pool->submit(new class($job) extends Threaded {
public function __construct(int $job) {
$this->job = $job;
}
public function run() {
var_dump($this->job);
}
});
}
$pool->shutdown();
?>
显然,这些工作毫无意义.在现实世界中,我猜你的$jobs数组一直在增长,所以你可以只更换foreach for some {},并继续调用:: submit来获取新的工作.
在现实世界中,您将希望在同一个循环中收集垃圾(只需调用Pool :: collect而不使用默认行为的参数).
值得注意的是,如果真的是PHP不打算在多线程环境中工作的话,这一切都不可能……这绝对是.
这就是问题的答案,但它并不能使它成为解决问题的最佳方案.
您在评论中提到,假设执行Symfony代码的8个线程占用的内存少于8个进程.事实并非如此,PHP始终没有任何共享.你可以期望8个Symfony线程占用8个Symfony进程的内存,事实上,更多一点.在进程上使用线程的好处是它们可以相互通信,同步和(看似)共享.
只因为你可以,并不意味着你应该.手头任务的最佳解决方案可能是使用一些现成的软件包或用于执行所需操作的软件.
充分研究这些东西以实现强大的解决方案需要很长时间,而且您不希望部署第一个解决方案……
如果您决定忽略我的建议,并试一试,您可以在github存储库中找到许多用于pthreads的examples.
内容总结
以上是互联网集市为您收集整理的在PHP CLI中使用并行线程运行大循环全部内容，希望文章能够帮你解决在PHP CLI中使用并行线程运行大循环所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。