這篇文章主要為大家展示了“golang怎么正確關(guān)閉計時器”,內(nèi)容簡而易懂,條理清晰,希望能夠幫助大家解決疑惑,下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“golang怎么正確關(guān)閉計時器”這篇文章吧。
創(chuàng)新互聯(lián)是一家專業(yè)提供尖扎企業(yè)網(wǎng)站建設(shè),專注與成都做網(wǎng)站、網(wǎng)站設(shè)計、外貿(mào)營銷網(wǎng)站建設(shè)、H5響應(yīng)式網(wǎng)站、小程序制作等業(yè)務(wù)。10年已為尖扎眾多企業(yè)、政府機構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)絡(luò)公司優(yōu)惠進行中。
go的官方庫計時器, 有一個陷阱,ticker.Stop()如果不注意會導(dǎo)致協(xié)程無法關(guān)閉。
如果我們想強制中斷計時,該如何做?
下面示例便于理解
func main(){ ticker := time.NewTicker(time.Second*10) go func(){ log.Println("go start") select{ case <-ticker.C: log.Println("ticker stop") } //會發(fā)現(xiàn)這一句化一直不打印 log.Println("go end") }() time.Sleep(1) //stop無法結(jié)束上面的協(xié)程 ticker.Stop() time.Sleep(20) log.Println("main end") }
func WaitResponse(queueChan *chan Packet, timeout time.Duration) *Packet, error{ ticker := time.NewTicker(time.Second*timeout) defer ticker.Stop() var response Packet var err error select{ case response = <-*queueChan: if response == "標(biāo)記值xxx"{ return nil, errors.New("terminate response") } case <-ticker.C: err = errors.New("wait response timeout") } return &response, err } go WaitResponse(queueChan, time.Duration(60)) queueChan <- "標(biāo)記值xxx"
以上是“golang怎么正確關(guān)閉計時器”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對大家有所幫助,如果還想學(xué)習(xí)更多知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道!
名稱欄目:golang怎么正確關(guān)閉計時器
當(dāng)前鏈接:http://chinadenli.net/article40/jieeho.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供、網(wǎng)頁設(shè)計公司、虛擬主機、網(wǎng)站制作、網(wǎng)站設(shè)計、搜索引擎優(yōu)化
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)