x

@@ -37,8 +37,8 @@ class SendJob {
                     }
                     }
 
 
                     $this->go_($list);
                     $this->go_($list);
-
-
+                    // 防止协程太快
+                    co::sleep(1);
                 }
                 }
             }else{
             }else{
                 _echo('没有找到任务');
                 _echo('没有找到任务');
@@ -208,7 +208,7 @@ class SendJob {
 $pm = new Process\Manager();
 $pm = new Process\Manager();
 
 
 // 启动业务进程
 // 启动业务进程
-$pm->addBatch(2,function (Process\Pool $pool, int $worker_id) {
+$pm->addBatch(3,function (Process\Pool $pool, int $worker_id) {
     if($worker_id==0){
     if($worker_id==0){
         $time = time();
         $time = time();
         while (1){
         while (1){