diff --git a/Console/AbstractConsole.php b/Console/AbstractConsole.php index 85f38e95..7bc73d49 100644 --- a/Console/AbstractConsole.php +++ b/Console/AbstractConsole.php @@ -8,6 +8,7 @@ use Exception; use Snowflake\Abstracts\Component; use Snowflake\Abstracts\Input; use Snowflake\Snowflake; +use Swoole\Coroutine; use Swoole\Coroutine\Channel; /** diff --git a/Database/Pagination.php b/Database/Pagination.php index 69a99b43..dfc0aa17 100644 --- a/Database/Pagination.php +++ b/Database/Pagination.php @@ -118,7 +118,7 @@ class Pagination extends Component public function plunk($param = []) { $this->_group = new Coroutine\WaitGroup(); - $this->loop($param); + Coroutine::create([$this, 'loop'], $param); $this->_group->wait(); } @@ -172,16 +172,15 @@ class Pagination extends Component * @param $callback * @param $data * @param $param - * @return Closure * 解释器 */ private function executed($callback, $data, $param) { $this->_group->add(1); - return Coroutine::create(function ($callback, $data, $param) { + go(function () use ($callback, $data, $param) { call_user_func($callback, $data, $param); $this->_group->done(); - }, $callback, $data, $param); + }); }