dev

helper/queue/iqueue.php

@@ -247,8 +247,7 @@ abstract class ILooper
 
         $this->_pause = 1;
         do{
-//            Swoole\Coroutine::sleep(1);
-            Co::sleep(1);
+            Swoole\Coroutine::sleep(1);
         } while($this->_pause == 1);
         $this->wait();
 
@@ -273,6 +272,7 @@ abstract class ILooper
 
     private function wait()
     {
+        include "./abc.php";
         do {
             $res = Swoole\Coroutine::stats();
             $num = $res['coroutine_num'];