package main
import (
   "fmt"
   "github.com/gogf/gf/container/gqueue"
   "github.com/gogf/gf/os/gtimer"
   "time"
)
func main() {
   //實例化gqueue
   q := gqueue.New()
   //數(shù)據(jù)生產(chǎn)者 每隔1秒想隊列寫入1條數(shù)據(jù)
   gtimer.SetInterval(time.Second, func() {
      nowStr := time.Now().String()
      q.Push(nowStr)
   })
   //3秒后關(guān)閉隊列
   gtimer.SetTimeout(time.Second*3, func() {
      fmt.Println("關(guān)閉隊列")
      q.Close()
   })
   // 消費者 不停的從隊列中取值輸出到終端中
   for {
      if v := q.Pop(); v != nil {
         fmt.Println("消費者接收：", v)
      } else {
         break
      }
   }
}
復(fù)制代碼

打印結(jié)果

優(yōu)勢

為什么不用標準庫的channel，要用gqueue呢？

gqueue的使用比channel更靈活，channel有隊列大小的限制，而gqueue隊列支持動態(tài)大小
channel的讀寫性能確實非常高，但是channel創(chuàng)建的時候需要初始化內(nèi)存，初始化操作效率非常低；而gqueue的創(chuàng)建效率非常高，gqueue是動態(tài)創(chuàng)建內(nèi)存。

底層實現(xiàn)

gqueue的底層實現(xiàn)是基于glist實現(xiàn)動態(tài)大小的特性，在隊列滿或者隊列空時讀取數(shù)據(jù)會產(chǎn)生阻塞。

glist是一個并發(fā)安全的鏈接，支持關(guān)閉并發(fā)安全的特性，當(dāng)關(guān)閉并發(fā)安全的特性時和普通鏈表無異，在存儲和讀取數(shù)據(jù)時，不會產(chǎn)生阻塞。

阻止進程銷毀

select{}的作用可以阻止進程銷毀

package main
import (
   "fmt"
   "github.com/gogf/gf/container/gqueue"
   "github.com/gogf/gf/os/gtime"
   "github.com/gogf/gf/os/gtimer"
   "time"
)
func main() {
   //實例化隊列
   queue := gqueue.New()
   // 生產(chǎn)者每隔1秒鐘向隊列寫入一條數(shù)據(jù)
   gtimer.SetInterval(time.Second, func() {
      queue.Push(gtime.Now().String())
   })
   //消費者 常駐內(nèi)存一直接收生產(chǎn)者的數(shù)據(jù)
   for {
      select {
      case v := &lt;-queue.C: //C是 chan interface{}
         if v != nil {
            fmt.Println("消費者：", v)
         } else {
            return
         }
      }
   }
}
復(fù)制代碼

運行結(jié)果

如下圖所示，select{}可以阻止進程銷毀，gtimer一直在生產(chǎn)數(shù)據(jù)，而for循環(huán)中的select一直在消費數(shù)據(jù)。

總結(jié)

以上就是goFrame的gqueue對比channel使用詳解的詳細內(nèi)容，通過這篇文章，我們知道了channel的概念和作用。也知道了gqueue的底層實現(xiàn)和特點，以及gqueue和channel的對比。兩者各有什么特點，更多關(guān)于goFrame gqueue對比channel的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: