sync

@@ -17,9 +17,18 @@ function start(){
     $pm = new Process\Manager();
     $pm = new Process\Manager();
 
 
     // 启动业务进程
     // 启动业务进程
-    $pm->addBatch(10,function (Process\Pool $pool, int $worker_id){
+    $pm->addBatch(11,function (Process\Pool $pool, int $worker_id){
 
 
-        swoole_set_process_name('php-email-sync-list-'.$worker_id);
+        if($worker_id===0){
+            $i=43200;
+            while($i>0){
+                $i--;
+                co::sleep(1);
+
+            }
+            $pool->shutdown();
+            return 0;
+        }
 
 
         include_once __DIR__."/../vendor/autoload.php";
         include_once __DIR__."/../vendor/autoload.php";
         _echo("业务进程（{$worker_id}）启动成功");
         _echo("业务进程（{$worker_id}）启动成功");

@@ -5,7 +5,19 @@
 $pm = new \Swoole\Process\Manager();
 $pm = new \Swoole\Process\Manager();
 
 
 // 启动业务进程
 // 启动业务进程
-$pm->addBatch(2,function (\Swoole\Process\Pool $pool, int $worker_id){
+$pm->addBatch(3,function (\Swoole\Process\Pool $pool, int $worker_id){
+
+    if($worker_id===0){
+        $i=600;
+        while($i>0){
+            $i--;
+            co::sleep(1);
+
+        }
+        $pool->shutdown();
+        return 0;
+    }
+
     //error_reporting();
     //error_reporting();
     include_once __DIR__."/../vendor/autoload.php";
     include_once __DIR__."/../vendor/autoload.php";
 
 
@@ -23,7 +35,7 @@ $pm->addBatch(2,function (\Swoole\Process\Pool $pool, int $worker_id){
         // _echo('读取到'.$id);
         // _echo('读取到'.$id);
         if($id && is_numeric($id)){
         if($id && is_numeric($id)){
             // 占用当前的id,占用2小时
             // 占用当前的id,占用2小时
-            if(redis()->add('just_sync_'.$id,time(),600)){
+            if(redis()->add('just_sync_'.$id,time(),300)){
 
 
                 \Lib\SwGo::start(function ($id){
                 \Lib\SwGo::start(function ($id){