作者 邓超

xxx

@@ -6,9 +6,6 @@ use Swoole\Process; @@ -6,9 +6,6 @@ use Swoole\Process;
6 6
7 7
8 8
9 -include_once __DIR__."/../vendor/autoload.php";  
10 -  
11 -  
12 function start(){ 9 function start(){
13 10
14 // 删除停止运行的值 11 // 删除停止运行的值
@@ -22,6 +19,8 @@ function start(){ @@ -22,6 +19,8 @@ function start(){
22 _echo("业务进程({$worker_id})启动成功"); 19 _echo("业务进程({$worker_id})启动成功");
23 swoole_set_process_name('php-email-sync-list-'.$worker_id); 20 swoole_set_process_name('php-email-sync-list-'.$worker_id);
24 21
  22 + include_once __DIR__."/../vendor/autoload.php";
  23 +
25 $run_timer = time(); 24 $run_timer = time();
26 // 循环阻塞 25 // 循环阻塞
27 while (true){ 26 while (true){
@@ -72,6 +71,9 @@ function start(){ @@ -72,6 +71,9 @@ function start(){
72 $pm->add(function (Process\Pool $pool, int $worker_id){ 71 $pm->add(function (Process\Pool $pool, int $worker_id){
73 _echo("业务进程({$worker_id})启动成功,body"); 72 _echo("业务进程({$worker_id})启动成功,body");
74 swoole_set_process_name('php-email-sync-body-'.$worker_id); 73 swoole_set_process_name('php-email-sync-body-'.$worker_id);
  74 +
  75 + include_once __DIR__."/../vendor/autoload.php";
  76 +
75 $run_timer = time(); 77 $run_timer = time();
76 // 循环阻塞 78 // 循环阻塞
77 while (true){ 79 while (true){