N個(gè)群進(jìn)行發(fā)消息，視頻，圖片，文字。視頻圖片文字之間有個(gè)五秒的延遲，一開始用的sleep，導(dǎo)致時(shí)間間隔壓根不對，現(xiàn)在用定時(shí)器去操作，又遇到了定時(shí)器阻塞問題。

循環(huán)讀取群，批量往群內(nèi)去發(fā)送視頻圖片文字。請問這種情況用workman怎么寫，如果是原生php之間用sleep去寫了。但workman里面用sleep又導(dǎo)致了其他的業(yè)務(wù)阻塞。已經(jīng)用了AsyncTcpConnection

我的業(yè)務(wù)比較復(fù)雜。

15分鐘讀取機(jī)器人id，根據(jù)機(jī)器人id讀取他的群，循環(huán)發(fā)送這些群。
現(xiàn)在的寫法如下：

    public function sendRobotAllGroup($wxId,$group=[]){

        foreach ($group as $k=>$v){
            if(!$v['wechatgroup_code']){
                Db::name('wechatgroup')->where('id',$v['id'])->update(['status'=>6]);
                continue;
            }
            $send = new Send();
            $send->setGroupId($v['id']);
            //獲取內(nèi)容
            $content = $send->index();

            if($k==0){
                $space = 1;
            }else{
                $space = $k*4;
            }
            //發(fā)送
            Timer::add($space, array($this, 'sendByWxId'), [$wxId, $v['wechatgroup_code'] ,$content], false);
      //      $this->sendByWxId($wxId,$v['wechatgroup_code'],$content);

            unset($content);
            unset($send);
        }
    }

    public function sendBysWxId($fromId,$toId,$content){
        $vedio      = $content['vedio']; //視頻
        $pic_urls   = $content['pic_urls'];   //圖片
        $text       = $content['content'];        //文案
        $i = 0;
        $curr = 0;  //當(dāng)前位置  0 視頻 1 圖片 2文案
        $v_count = count($vedio);
        $p_count = count($pic_urls);
        $t_count = count($text);

        $timer_id = Timer::add(5, function()use(&$timer_id ,&$fromId, &$toId, &$vedio,&$pic_urls, &$text,&$v_count,&$p_count,&$t_count, &$i ,&$curr)
        {
            if($curr == 0){
                if($i == $v_count){
                    $i = 0;
                    $curr = 1;
                }else{
                    $this->sendVideo($fromId, $toId, $vedio[$i]);
                }
            }
            if ($curr == 1){
                if($i == $p_count){
                    $i = 0;
                    $curr = 2;
                }else{
                    $this->sendImage($fromId, $toId, $pic_urls[$i]);
                }
            }
            if ($curr == 2){
                if($i == $t_count){
                    $i = 0;
                }else{
                    $this->sendText($fromId, $toId, $text[$i]);
                }
            }
            $i++;
            if($i >= $t_count && $curr ==2){
                Timer::del($timer_id);
            }
        });

    }

現(xiàn)在應(yīng)該是遇到定時(shí)器阻塞，循環(huán)創(chuàng)建的定時(shí)器，如果前面一個(gè)定時(shí)器還沒有跑完，那下面的定時(shí)器是不是不會(huì)執(zhí)行？都要等著他執(zhí)行萬，別告訴我再來一個(gè) AsyncTcpConnection 。我已經(jīng)做了客戶端定時(shí)15分鐘發(fā)起發(fā)送請求，然后AsyncTcpConnection到服務(wù)端來處理發(fā)送了。

sendText ， sendImage ，sendVideo都是curl http接口
請大神指點(diǎn)下。