x

@@ -23,9 +23,15 @@ function start(){
         _echo("业务进程（{$worker_id}）启动成功");
         _echo("业务进程（{$worker_id}）启动成功");
 
 
         $goNum = 0;
         $goNum = 0;
+        $timer = time();
         // 循环阻塞
         // 循环阻塞
         while (true){
         while (true){
 
 
+            if(time()-$timer > 3600){
+                break;
+            }
+
+
             // 需要同步的id
             // 需要同步的id
             $id = redis()->lPop('sync_email_lists');
             $id = redis()->lPop('sync_email_lists');