goFrame的gqueue與channe的區(qū)別
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ù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
GoFrame通用類型變量gvar與interface基本使用對比
這篇文章主要為大家介紹了GoFrame通用類型變量gvar與interface基本使用對比,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-06-06

