1

application/admin/controller/Queue.php

@@ -53,9 +53,8 @@ class Queue extends Controller
             $this->command = ProcessService::instance()->think('xtask:start');
             $this->listen = preg_match('/process.*?\d+.*?running/', $this->message, $attr);
 
-//            $listen = ProcessService::instance()->query('xtask:_work');
-//            dump($listen);
-
+            $listen = ProcessService::instance()->query('xtask:_work 71 -');
+            dump($listen);
         } catch (\Exception $exception) {
             $this->listen = false;
             $this->message = $exception->getMessage();