代码拉取完成,页面将自动刷新
composer require flc/php-queue
producer
/**
* 任务创建
*/
require_once __DIR__ . '/bootstrap.php';
use Flc\Queue\Manager;
use Jobs\Demo;
// 创建工作
$demo = new Demo('测试');
// 推送到队列
for ($i = 0; $i <= 100; $i ++) {
Manager::instance()->push($demo);
}
echo Manager::instance()->count();
consumer
/**
* 任务执行者(常驻)
*/
require_once __DIR__ . '/bootstrap.php';
use Flc\Queue\Manager;
use Jobs\Demo;
if ('cli' !== php_sapi_name()) {
die('必须在命令行模式下运行');
}
while (true) {
// 从队列拉取任务
$job = Manager::instance()->pull();
// 如无任务,则休息2秒
if (! $job) {
sleep(2);
continue;
}
try {
call_user_func_array([$job, 'handle'], []);
} catch (Exception $e) {
echo $e->getMessage();
}
}
MIT
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型