...
|
...
|
@@ -16,10 +16,11 @@ function start(){ |
|
|
|
|
|
// 启动业务进程
|
|
|
$pm->addBatch(10,function (Process\Pool $pool, int $worker_id){
|
|
|
_echo("业务进程({$worker_id})启动成功");
|
|
|
|
|
|
swoole_set_process_name('php-email-sync-list-'.$worker_id);
|
|
|
|
|
|
include_once __DIR__."/../vendor/autoload.php";
|
|
|
_echo("业务进程({$worker_id})启动成功");
|
|
|
|
|
|
$run_timer = time();
|
|
|
// 循环阻塞
|
...
|
...
|
@@ -69,11 +70,12 @@ function start(){ |
|
|
|
|
|
// 启动一个同步内容的进程
|
|
|
$pm->add(function (Process\Pool $pool, int $worker_id){
|
|
|
_echo("业务进程({$worker_id})启动成功,body");
|
|
|
|
|
|
swoole_set_process_name('php-email-sync-body-'.$worker_id);
|
|
|
|
|
|
include_once __DIR__."/../vendor/autoload.php";
|
|
|
|
|
|
_echo("业务进程({$worker_id})启动成功,body");
|
|
|
$run_timer = time();
|
|
|
// 循环阻塞
|
|
|
while (true){
|
...
|
...
|
|