public static function onWorkerStart($businessWorker)
    {
        $inner_http_worker = new Worker('http://0.0.0.0:7080');
   $inner_http_worker->onMessage = function($http_connection, $data) use ($mqtt,$exporter,$http){
              $http_connection->send('');
            $_POST = $_POST ? $_POST : $_GET;

            $message = @$_POST['msg'];
            $ident = @$_POST['ident'];
            $operator = @$_POST['operator'];

            if($operator == 'EditPerson') sleep(2);
``` $payload['info'] = $message;
         if(isset($payload['info']['picURI'])){
         $payload['info']['picURI'] = urlencode($payload['info']['picURI']);}
         if(isset($payload['info']['path'])){
         $payload['info']['path'] = urlencode($payload['info']['path']);}

            $payload = json_encode($payload, JSON_UNESCAPED_UNICODE);
            $payload = urldecode($payload);

            $options['qos'] = 2;
            var_dump($payload);
            $mqtt->publish($ident,$payload,$options);
         };

RT
這個代碼因為某些原因，需要后面的操作延時2秒執(zhí)行，我寫了sleep(2),新的數(shù)據(jù)post進來要等兩秒以后。
我想要的結(jié)果是后面的操作延時2秒執(zhí)行，但同時可以接收新的post 數(shù)據(jù)。