| 
...
 | 
...
 | 
@@ -16,7 +16,7 @@ function start(){ | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
     $id = 0;
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
     $goNum = 0;
 | 
| 
 | 
 | 
 //    $goNum = 0;
 | 
| 
 | 
 | 
     // 循环阻塞
 | 
| 
 | 
 | 
     while (true){
 | 
| 
 | 
 | 
 
 | 
| 
...
 | 
...
 | 
@@ -24,8 +24,8 @@ function start(){ | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
         if($id){
 | 
| 
 | 
 | 
             // 启动一个协程
 | 
| 
 | 
 | 
             go(function () use ($id,&$goNum){
 | 
| 
 | 
 | 
                 $goNum++;
 | 
| 
 | 
 | 
 //            go(function () use ($id,&$goNum){
 | 
| 
 | 
 | 
 //                $goNum++;
 | 
| 
 | 
 | 
                 // 开始同步
 | 
| 
 | 
 | 
                 try {
 | 
| 
 | 
 | 
                     sync($id);
 | 
| 
...
 | 
...
 | 
@@ -34,19 +34,19 @@ function start(){ | 
| 
 | 
 | 
                 }
 | 
| 
 | 
 | 
                 \Lib\Log::getInstance()->write();
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
                 co::defer(function () use (&$goNum){
 | 
| 
 | 
 | 
                     $goNum--;
 | 
| 
 | 
 | 
                 });
 | 
| 
 | 
 | 
             });
 | 
| 
 | 
 | 
 //                co::defer(function () use (&$goNum){
 | 
| 
 | 
 | 
 //                    $goNum--;
 | 
| 
 | 
 | 
 //                });
 | 
| 
 | 
 | 
 //            });
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
         }else{
 | 
| 
 | 
 | 
             break;
 | 
| 
 | 
 | 
         }
 | 
| 
 | 
 | 
     }
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
     while ($goNum>0){
 | 
| 
 | 
 | 
         co::sleep(1);
 | 
| 
 | 
 | 
     }
 | 
| 
 | 
 | 
 //    while ($goNum>0){
 | 
| 
 | 
 | 
 //        co::sleep(1);
 | 
| 
 | 
 | 
 //    }
 | 
| 
 | 
 | 
     _echo('结束了');
 | 
| 
 | 
 | 
 }
 | 
| 
 | 
 | 
 
 | 
...
 | 
...
 | 
 |