| 
...
 | 
...
 | 
@@ -32,13 +32,14 @@ function start(){ | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
         include_once __DIR__."/../vendor/autoload.php";
 | 
| 
 | 
 | 
         _echo("业务进程({$worker_id})启动成功");
 | 
| 
 | 
 | 
         \Lib\DbPool::$clientNumber = 60;
 | 
| 
 | 
 | 
         $goNum = 0;
 | 
| 
 | 
 | 
         \Lib\DbPool::$clientNumber = 55;
 | 
| 
 | 
 | 
         \Lib\RedisPool::$clientNumber = 55;
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
         // 循环阻塞
 | 
| 
 | 
 | 
         while (true){
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
             while ($goNum > 50){
 | 
| 
 | 
 | 
                 co::sleep(0.5);
 | 
| 
 | 
 | 
             while (\Lib\SwGo::$runNumber > 50){
 | 
| 
 | 
 | 
                 co::sleep(1);
 | 
| 
 | 
 | 
                 continue;
 | 
| 
 | 
 | 
             }
 | 
| 
 | 
 | 
             // 需要同步的id
 | 
| 
...
 | 
...
 | 
@@ -48,10 +49,8 @@ function start(){ | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
                 // 占用当前的id,占用2小时
 | 
| 
 | 
 | 
                 if(redis()->add('just_sync_'.$id,time(),600)){
 | 
| 
 | 
 | 
 //                    redis()->set('sync_my_pid:'.getmypid(),time(),86400);
 | 
| 
 | 
 | 
                     // 启动一个协程
 | 
| 
 | 
 | 
                     go(function () use ($id,&$goNum){
 | 
| 
 | 
 | 
                         $goNum++;
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
                     \Lib\SwGo::start(function ($id){
 | 
| 
 | 
 | 
                         try{
 | 
| 
 | 
 | 
                             // 开始同步
 | 
| 
 | 
 | 
                             $email = db()->cache(3600)->first(\Model\emailSql::first($id));
 | 
| 
...
 | 
...
 | 
@@ -73,23 +72,15 @@ function start(){ | 
| 
 | 
 | 
                         }
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
                         // 协程完成后执行的函数
 | 
| 
 | 
 | 
                         co::defer(function () use ($id,&$goNum){
 | 
| 
 | 
 | 
                             $goNum--;
 | 
| 
 | 
 | 
                         // 30秒后 消除占用
 | 
| 
 | 
 | 
                         redis()->expire('just_sync_'.$id,120);
 | 
| 
 | 
 | 
                             // 写入日志
 | 
| 
 | 
 | 
                             \Lib\Log::getInstance()->write();
 | 
| 
 | 
 | 
                             // 手动释放
 | 
| 
 | 
 | 
                             db()->close();
 | 
| 
 | 
 | 
                         });
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
                     });
 | 
| 
 | 
 | 
                     },$id);
 | 
| 
 | 
 | 
                 }
 | 
| 
 | 
 | 
             }
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
             //每次都暂停1秒,防止同一时间启动太多的任务
 | 
| 
 | 
 | 
             co::sleep(0.1);
 | 
| 
 | 
 | 
             co::sleep(0.2);
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
         }
 | 
| 
 | 
 | 
 
 | 
...
 | 
...
 | 
 |