channel

首先明確一下channel的作用：用于go協程間的通信。

go語言最大的特點就是支持高并發(fā)：goroutine和channel是支持高并發(fā)的重要組成部分。

單純地將函數并發(fā)執(zhí)行是沒有意義的。函數與函數間需要交換數據才能體現并發(fā)執(zhí)行函數的意義。

如果說 goroutine 是Go程序并發(fā)的執(zhí)行體，channel就是它們之間的連接。channel是可以讓一個 goroutine 發(fā)送特定值到另一個 goroutine 的通信機制。

另外要明確知道go的并發(fā)哲學，銘記這句原則：用通信來共享內存，而不要用共享內存來通信。

在搞清楚channel的作用之后我們再來研究GoFrame框架（下文簡稱gf）中gqueue的特點。

gqueue

概念

隊列 gqueue 動態(tài)大小的并發(fā)安全隊列

gqueue也可以設置為固定大小的隊列，固定大小時和標準庫channel沒區(qū)別。簡單來說channel實現的功能gqueue也能實現。

使用場景：

gqueue是并發(fā)安全的，常用于多個goroutine數據通信且支持動態(tài)隊列大小的場景

代碼演示：

package main
import (
   "fmt"
   "github.com/gogf/gf/container/gqueue"
   "github.com/gogf/gf/os/gtimer"
   "time"
)

func main() {
   //實例化gqueue
   q := gqueue.New()
   //數據生產者 每隔1秒想隊列寫入1條數據
   gtimer.SetInterval(time.Second, func() {
      nowStr := time.Now().String()
      q.Push(nowStr)
   })

   //3秒后關閉隊列
   gtimer.SetTimeout(time.Second*3, func() {
      fmt.Println("關閉隊列")
      q.Close()
   })

   // 消費者 不停的從隊列中取值輸出到終端中
   for {
      if v := q.Pop(); v != nil {
         fmt.Println("消費者接收：", v)
      } else {
         break
      }
   }
}

打印結果：

優(yōu)勢

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

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

底層實現

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

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

阻止進程銷毀

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()
   // 生產者每隔1秒鐘向隊列寫入一條數據
   gtimer.SetInterval(time.Second, func() {
      queue.Push(gtime.Now().String())
   })
   //消費者 常駐內存一直接收生產者的數據
   for {
      select {
      case v := <-queue.C: //C是 chan interface{}
         if v != nil {
            fmt.Println("消費者：", v)
         } else {
            return
         }
      }
   }
}

運行結果：

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

總結

通過這篇文章，我們知道了channel的概念和作用。也知道了gqueue的底層實現和特點，以及gqueue和channel的對比。兩者各有什么特點。

到此這篇關于goFrame的gqueue與channe的區(qū)別的文章就介紹到這了,更多相關goFrame的gqueue內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

最新評論