dev

helper/queue/iqueue.php

@@ -247,7 +247,8 @@ abstract class ILooper
 
         $this->_pause = 1;
         do{
-            Swoole\Coroutine::sleep(1);
+//            Swoole\Coroutine::sleep(1);
+            Co::sleep(1);
         } while($this->_pause == 1);
         $this->wait();