golang優(yōu)先級(jí)隊(duì)列的實(shí)現(xiàn)全過程
前言
在數(shù)據(jù)結(jié)構(gòu)中，隊(duì)列遵循著FIFO（先進(jìn)先出）的規(guī)則。在此基礎(chǔ)上，人們引申出了“優(yōu)先級(jí)隊(duì)列”的概念。
優(yōu)先級(jí)隊(duì)列，是帶有優(yōu)先級(jí)屬性的隊(duì)列，所有的隊(duì)列元素按照優(yōu)先級(jí)進(jìn)行排序，消費(fèi)者會(huì)先對(duì)優(yōu)先級(jí)高的隊(duì)列元素進(jìn)行處理。
優(yōu)先級(jí)隊(duì)列的使用場(chǎng)景也是非常多的。比如，作業(yè)調(diào)度系統(tǒng)，當(dāng)一個(gè)作業(yè)完成后，需要從剩下的作業(yè)中取出優(yōu)先級(jí)最高的作業(yè)進(jìn)行處理。又比如，一個(gè)商城的用戶分為普通用戶和vip用戶，vip用戶更容易搶到那些秒殺商品。
在本文中，我將和大家一起探討，golang優(yōu)先級(jí)隊(duì)列的一種實(shí)現(xiàn)方案。
你可以收獲
- golang切片特性
- golang map特性
- golang并發(fā)場(chǎng)景下的解決方案
- golang優(yōu)先級(jí)隊(duì)列的實(shí)現(xiàn)思路
正文
內(nèi)容脈絡(luò)
為了讓大家腦海里有個(gè)大致的輪廓，我先把正文的大綱展示出來。
基礎(chǔ)知識(shí)
在正式開始“優(yōu)先級(jí)隊(duì)列”這個(gè)話題之前，我們首先要明確以下的一些golang特性。
切片的特性
- 元素的有序性
- 非線程安全
map的特性
- 元素的無序性
- 非線程安全
并發(fā)場(chǎng)景下的解決方案
- 互斥鎖：可以對(duì)非線程安全的數(shù)據(jù)結(jié)構(gòu)創(chuàng)建臨界區(qū)，一般用于同步場(chǎng)景；
- 管道：可以對(duì)非線程安全的數(shù)據(jù)結(jié)構(gòu)進(jìn)行異步處理
實(shí)現(xiàn)思路
既然，我們了解了golang的一些特性，那么，我們接下來就要明確，如何去實(shí)現(xiàn)優(yōu)先級(jí)隊(duì)列了。
我們都知道，無論是哪一種隊(duì)列，必然是存在生產(chǎn)者和消費(fèi)者兩個(gè)部分，對(duì)于優(yōu)先級(jí)隊(duì)列來說，更是如此。因此，咱們的實(shí)現(xiàn)思路，也將從這兩個(gè)部分來談。
1、生產(chǎn)者
對(duì)于生產(chǎn)者來說，他只需要推送一個(gè)任務(wù)及其優(yōu)先級(jí)過來，咱們就得根據(jù)優(yōu)先級(jí)處理他的任務(wù)。
由于，我們不大好判斷，到底會(huì)有多少種不同的優(yōu)先級(jí)傳過來，也無法確定，每種優(yōu)先級(jí)下有多少個(gè)任務(wù)要處理，所以，我們可以考慮使用map來存儲(chǔ)優(yōu)先級(jí)隊(duì)列。其中key為優(yōu)先級(jí)，value為屬于該優(yōu)先級(jí)下的任務(wù)隊(duì)列（即管道） 。
2、消費(fèi)者
對(duì)于消費(fèi)者來說，他需要獲取優(yōu)先級(jí)最高的任務(wù)進(jìn)行消費(fèi)。
但是，如果只按照上面所說的map來存儲(chǔ)優(yōu)先級(jí)隊(duì)列的話，我們是沒法找到優(yōu)先級(jí)最高的任務(wù)隊(duì)列的，因?yàn)閙ap的元素是無序的。那么，我們?cè)趺刺幚磉@個(gè)問題呢？
我們都知道，在golang的數(shù)據(jù)結(jié)構(gòu)里，切片的元素是具有有序性的。那么，我們只需要將所有的優(yōu)先級(jí)按從小到大的方式，存儲(chǔ)在一個(gè)切片里，就可以了。等到消費(fèi)的時(shí)候，我們可以先從切片中，取出最大的優(yōu)先級(jí)，然后再根據(jù)這個(gè)key去優(yōu)先級(jí)隊(duì)列的map中查詢，是不是就可以了？
目標(biāo)規(guī)劃
想好了實(shí)現(xiàn)思路之后，我們就得對(duì)接下來的代碼實(shí)現(xiàn)做一個(gè)規(guī)劃了。
數(shù)據(jù)結(jié)構(gòu)
- 存儲(chǔ)優(yōu)先級(jí)隊(duì)列的map
- 存儲(chǔ)優(yōu)先級(jí)的切片
- 互斥鎖
- 其他......
生產(chǎn)者
- 添加任務(wù)到優(yōu)先級(jí)隊(duì)列
消費(fèi)者
- 從優(yōu)先級(jí)隊(duì)列獲取任務(wù)
步步為營(yíng)
1、數(shù)據(jù)流
（1）調(diào)用NewPriorityQueue() ，初始化優(yōu)先級(jí)隊(duì)列對(duì)象。
（2）初始化優(yōu)先級(jí)隊(duì)列map。
（3）開啟協(xié)程，監(jiān)聽一個(gè)接收推送任務(wù)的全局管道pushChan。
（4）用戶調(diào)用Push() ，推送的任務(wù)進(jìn)入pushChan。
（5）推送的任務(wù)被加到優(yōu)先級(jí)隊(duì)列中。
（6）消費(fèi)者從優(yōu)先級(jí)隊(duì)列中獲取優(yōu)先級(jí)最高的一個(gè)任務(wù)。
（7）消費(fèi)者執(zhí)行任務(wù)。
2、數(shù)據(jù)結(jié)構(gòu)
（1）優(yōu)先級(jí)隊(duì)列對(duì)象
type PriorityQueue struct {
mLock sync.Mutex // 互斥鎖，queues和priorities并發(fā)操作時(shí)使用
queues map[int]chan *task // 優(yōu)先級(jí)隊(duì)列map
pushChan chan *task // 推送任務(wù)管道
priorities []int // 記錄優(yōu)先級(jí)的切片（優(yōu)先級(jí)從小到大排列）
}（2）任務(wù)對(duì)象
type task struct {
priority int // 任務(wù)的優(yōu)先級(jí)
f func() // 任務(wù)的執(zhí)行函數(shù)
}3、初始化優(yōu)先級(jí)隊(duì)列對(duì)象
func NewPriorityQueue() *PriorityQueue {
pq := &PriorityQueue{
queues: make(map[int]chan *task), // 初始化優(yōu)先級(jí)隊(duì)列map
pushChan: make(chan *task, 100),
}
return pq
}當(dāng)然，在這個(gè)過程中，我們需要對(duì)pushChan進(jìn)行監(jiān)聽。如果有任務(wù)推送過來，咱們得處理。
func (pq *PriorityQueue) listenPushChan() {
for {
select {
case taskEle := <-pq.pushChan:
// TODO 這里接收到推送的任務(wù)，并且準(zhǔn)備處理
}
}
}將這個(gè)監(jiān)聽函數(shù)放到NewPriorityQueue()中：
func NewPriorityQueue() *PriorityQueue {
pq := &PriorityQueue{
queues: make(map[int]chan *task),
pushChan: make(chan *task, 100),
}
// 監(jiān)聽pushChan
go pq.listenPushChan()
return pq
}4、生產(chǎn)者推送任務(wù)
生產(chǎn)者推送任務(wù)的時(shí)候，我們只需要將任務(wù)放到pushChan中：
func (pq *PriorityQueue) Push(f func(), priority int) {
pq.pushChan <- &task{
f: f,
priority: priority,
}
}5、將推送任務(wù)加到優(yōu)先級(jí)隊(duì)列中
這一步就比較關(guān)鍵了。我們前面談到，優(yōu)先級(jí)隊(duì)列最核心的數(shù)據(jù)結(jié)構(gòu)有兩個(gè)：優(yōu)先級(jí)隊(duì)列map和優(yōu)先級(jí)切片。因此，推送任務(wù)添加到優(yōu)先級(jí)隊(duì)列的操作，咱們得分兩種情況來看：
（1）之前已經(jīng)推過相同優(yōu)先級(jí)的任務(wù)
這種情況非常簡(jiǎn)單，咱們其實(shí)只要操作優(yōu)先級(jí)隊(duì)列map就可以了。
func (pq *PriorityQueue) listenPushChan() {
for {
select {
case taskEle := <-pq.pushChan:
priority := taskEle.priority
pq.mLock.Lock()
if v, ok := pq.queues[priority]; ok {
pq.mLock.Unlock()
// 之前推送過相同優(yōu)先級(jí)的任務(wù)
// 將推送的任務(wù)塞到對(duì)應(yīng)優(yōu)先級(jí)的隊(duì)列中
v <- taskEle
continue
}
// todo 之前未推過相同優(yōu)先級(jí)任務(wù)的處理...
}
}
}（2）之前未推過相同優(yōu)先級(jí)的任務(wù)
這種情況會(huì)稍微復(fù)雜一些。我們不僅要將新的優(yōu)先級(jí)插入到優(yōu)先級(jí)切片正確的位置，而且要將任務(wù)添加到對(duì)應(yīng)優(yōu)先級(jí)的隊(duì)列。
1）將新的優(yōu)先級(jí)插入到優(yōu)先級(jí)切片中
a. 首先，咱們得尋找新優(yōu)先級(jí)在切片中的插入位置。這里，咱們用了二分法。
// 通過二分法尋找新優(yōu)先級(jí)的切片插入位置
func (pq *PriorityQueue) getNewPriorityInsertIndex(priority int, leftIndex, rightIndex int) (index int) {
if len(pq.priorities) == 0 {
// 如果當(dāng)前優(yōu)先級(jí)切片沒有元素，則插入的index就是0
return 0
}
length := rightIndex - leftIndex
if pq.priorities[leftIndex] >= priority {
// 如果當(dāng)前切片中最小的元素都超過了插入的優(yōu)先級(jí)，則插入位置應(yīng)該是最左邊
return leftIndex
}
if pq.priorities[rightIndex] <= priority {
// 如果當(dāng)前切片中最大的元素都沒超過插入的優(yōu)先級(jí)，則插入位置應(yīng)該是最右邊
return rightIndex + 1
}
if length == 1 && pq.priorities[leftIndex] < priority && pq.priorities[rightIndex] >= priority {
// 如果插入的優(yōu)先級(jí)剛好在僅有的兩個(gè)優(yōu)先級(jí)之間，則中間的位置就是插入位置
return leftIndex + 1
}
middleVal := pq.priorities[leftIndex+length/2]
// 這里用二分法遞歸的方式，一直尋找正確的插入位置
if priority <= middleVal {
return pq.getNewPriorityInsertIndex(priority, leftIndex, leftIndex+length/2)
} else {
return pq.getNewPriorityInsertIndex(priority, leftIndex+length/2, rightIndex)
}
}b. 找到插入位置之后，我們才要插入。在這個(gè)過程中，插入位置右側(cè)的元素全部都要向右邊移動(dòng)一位。
// index右側(cè)元素均需要向后移動(dòng)一個(gè)單位
func (pq *PriorityQueue) moveNextPriorities(index, priority int) {
pq.priorities = append(pq.priorities, 0)
copy(pq.priorities[index+1:], pq.priorities[index:])
pq.priorities[index] = priority
}這樣，我們就成功地將新的優(yōu)先級(jí)插入了切片。
2）將推送任務(wù)放入優(yōu)先級(jí)隊(duì)列map也就順理成章。
// 創(chuàng)建一個(gè)新優(yōu)先級(jí)管道 pq.queues[priority] = make(chan *task, 10000) // 將任務(wù)塞到新的優(yōu)先級(jí)管道中 pq.queues[priority] <- taskEle
因此，listenPushChan()的代碼如下：
func (pq *PriorityQueue) listenPushChan() {
for {
select {
case taskEle := <-pq.pushChan:
priority := taskEle.priority
pq.mLock.Lock()
if v, ok := pq.queues[priority]; ok {
pq.mLock.Unlock()
// 將推送的任務(wù)塞到對(duì)應(yīng)優(yōu)先級(jí)的隊(duì)列中
v <- taskEle
continue
}
// 如果這是一個(gè)新的優(yōu)先級(jí)，則需要插入優(yōu)先級(jí)切片，并且新建一個(gè)優(yōu)先級(jí)的queue
// 通過二分法尋找新優(yōu)先級(jí)的切片插入位置
index := pq.getNewPriorityInsertIndex(priority, 0, len(pq.priorities)-1)
// index右側(cè)元素均需要向后移動(dòng)一個(gè)單位
pq.moveNextPriorities(index, priority)
// 創(chuàng)建一個(gè)新優(yōu)先級(jí)隊(duì)列
pq.queues[priority] = make(chan *task, 10000)
// 將任務(wù)塞到新的優(yōu)先級(jí)隊(duì)列中
pq.queues[priority] <- taskEle
pq.mLock.Unlock()
}
}
}完成了生產(chǎn)者部分之后，接下來我們看看消費(fèi)者。
6、消費(fèi)者消費(fèi)隊(duì)列
這里分成兩個(gè)步驟，首先咱們得拿到最高優(yōu)先級(jí)隊(duì)列的任務(wù)，然后再去執(zhí)行任務(wù)。代碼如下：
// 消費(fèi)者輪詢獲取最高優(yōu)先級(jí)的任務(wù)
func (pq *PriorityQueue) Consume() {
for {
task := pq.Pop()
if task == nil {
// 未獲取到任務(wù)，則繼續(xù)輪詢
continue
}
// 獲取到了任務(wù)，就執(zhí)行任務(wù)
task.f()
}
}
// 取出最高優(yōu)先級(jí)隊(duì)列中的一個(gè)任務(wù)
func (pq *PriorityQueue) Pop() *task {
pq.mLock.Lock()
defer pq.mLock.Unlock()
for i := len(pq.priorities) - 1; i >= 0; i-- {
if len(pq.queues[pq.priorities[i]]) == 0 {
// 如果當(dāng)前優(yōu)先級(jí)的隊(duì)列沒有任務(wù)，則看低一級(jí)優(yōu)先級(jí)的隊(duì)列中有沒有任務(wù)
continue
}
// 如果當(dāng)前優(yōu)先級(jí)的隊(duì)列里有任務(wù)，則取出一個(gè)任務(wù)。
return <-pq.queues[pq.priorities[i]]
}
// 如果所有隊(duì)列都沒有任務(wù)，則返回null
return nil
}7、完整代碼
這樣，咱們的優(yōu)先級(jí)隊(duì)列就實(shí)現(xiàn)了。下面，我們將完整代碼展示。
pq.go
package priority_queue
import (
"sync"
)
type PriorityQueue struct {
mLock sync.Mutex // 互斥鎖，queues和priorities并發(fā)操作時(shí)使用
queues map[int]chan *task // 優(yōu)先級(jí)隊(duì)列map
pushChan chan *task // 推送任務(wù)管道
priorities []int // 記錄優(yōu)先級(jí)的切片（優(yōu)先級(jí)從小到大排列）
}
type task struct {
priority int // 任務(wù)的優(yōu)先級(jí)
f func() // 任務(wù)的執(zhí)行函數(shù)
}
func NewPriorityQueue() *PriorityQueue {
pq := &PriorityQueue{
queues: make(map[int]chan *task),
pushChan: make(chan *task, 100),
}
go pq.listenPushChan()
return pq
}
func (pq *PriorityQueue) listenPushChan() {
for {
select {
case taskEle := <-pq.pushChan:
priority := taskEle.priority
pq.mLock.Lock()
if v, ok := pq.queues[priority]; ok {
pq.mLock.Unlock()
// 將推送的任務(wù)塞到對(duì)應(yīng)優(yōu)先級(jí)的隊(duì)列中
v <- taskEle
continue
}
// 如果這是一個(gè)新的優(yōu)先級(jí)，則需要插入優(yōu)先級(jí)切片，并且新建一個(gè)優(yōu)先級(jí)的queue
// 通過二分法尋找新優(yōu)先級(jí)的切片插入位置
index := pq.getNewPriorityInsertIndex(priority, 0, len(pq.priorities)-1)
// index右側(cè)元素均需要向后移動(dòng)一個(gè)單位
pq.moveNextPriorities(index, priority)
// 創(chuàng)建一個(gè)新優(yōu)先級(jí)隊(duì)列
pq.queues[priority] = make(chan *task, 10000)
// 將任務(wù)塞到新的優(yōu)先級(jí)隊(duì)列中
pq.queues[priority] <- taskEle
pq.mLock.Unlock()
}
}
}
// 插入work
func (pq *PriorityQueue) Push(f func(), priority int) {
pq.pushChan <- &task{
f: f,
priority: priority,
}
}
// index右側(cè)元素均需要向后移動(dòng)一個(gè)單位
func (pq *PriorityQueue) moveNextPriorities(index, priority int) {
pq.priorities = append(pq.priorities, 0)
copy(pq.priorities[index+1:], pq.priorities[index:])
pq.priorities[index] = priority
}
// 通過二分法尋找新優(yōu)先級(jí)的切片插入位置
func (pq *PriorityQueue) getNewPriorityInsertIndex(priority int, leftIndex, rightIndex int) (index int) {
if len(pq.priorities) == 0 {
// 如果當(dāng)前優(yōu)先級(jí)切片沒有元素，則插入的index就是0
return 0
}
length := rightIndex - leftIndex
if pq.priorities[leftIndex] >= priority {
// 如果當(dāng)前切片中最小的元素都超過了插入的優(yōu)先級(jí)，則插入位置應(yīng)該是最左邊
return leftIndex
}
if pq.priorities[rightIndex] <= priority {
// 如果當(dāng)前切片中最大的元素都沒超過插入的優(yōu)先級(jí)，則插入位置應(yīng)該是最右邊
return rightIndex + 1
}
if length == 1 && pq.priorities[leftIndex] < priority && pq.priorities[rightIndex] >= priority {
// 如果插入的優(yōu)先級(jí)剛好在僅有的兩個(gè)優(yōu)先級(jí)之間，則中間的位置就是插入位置
return leftIndex + 1
}
middleVal := pq.priorities[leftIndex+length/2]
// 這里用二分法遞歸的方式，一直尋找正確的插入位置
if priority <= middleVal {
return pq.getNewPriorityInsertIndex(priority, leftIndex, leftIndex+length/2)
} else {
return pq.getNewPriorityInsertIndex(priority, leftIndex+length/2, rightIndex)
}
}
// 取出最高優(yōu)先級(jí)隊(duì)列中的一個(gè)任務(wù)
func (pq *PriorityQueue) Pop() *task {
pq.mLock.Lock()
defer pq.mLock.Unlock()
for i := len(pq.priorities) - 1; i >= 0; i-- {
if len(pq.queues[pq.priorities[i]]) == 0 {
// 如果當(dāng)前優(yōu)先級(jí)的隊(duì)列沒有任務(wù)，則看低一級(jí)優(yōu)先級(jí)的隊(duì)列中有沒有任務(wù)
continue
}
// 如果當(dāng)前優(yōu)先級(jí)的隊(duì)列里有任務(wù)，則取出一個(gè)任務(wù)。
return <-pq.queues[pq.priorities[i]]
}
// 如果所有隊(duì)列都沒有任務(wù)，則返回null
return nil
}
// 消費(fèi)者輪詢獲取最高優(yōu)先級(jí)的任務(wù)
func (pq *PriorityQueue) Consume() {
for {
task := pq.Pop()
if task == nil {
// 未獲取到任務(wù)，則繼續(xù)輪詢
continue
}
// 獲取到了任務(wù)，就執(zhí)行任務(wù)
task.f()
}
}測(cè)試代碼pq_test.go：
package priority_queue
import (
"fmt"
"math/rand"
"testing"
"time"
)
func TestQueue(t *testing.T) {
defer func() {
if err := recover(); err != nil {
fmt.Println(err)
}
}()
pq := NewPriorityQueue()
rand.Seed(time.Now().Unix())
// 我們?cè)谶@里，隨機(jī)生成一些優(yōu)先級(jí)任務(wù)
for i := 0; i < 100; i++ {
a := rand.Intn(10)
go func(i int) {
pq.Push(func() {
fmt.Println("推送任務(wù)的編號(hào)為：", i)
fmt.Println("推送的任務(wù)優(yōu)先級(jí)為：", a)
fmt.Println("============")
}, a)
}(i)
}
// 這里會(huì)阻塞，消費(fèi)者會(huì)輪詢查詢?nèi)蝿?wù)隊(duì)列
pq.Consume()
}發(fā)散思維
上面的方案的確是實(shí)現(xiàn)了優(yōu)先級(jí)隊(duì)列，但是，有一種極端情況：如果消費(fèi)者的消費(fèi)速度遠(yuǎn)遠(yuǎn)小于生產(chǎn)者的生產(chǎn)速度，并且高優(yōu)先級(jí)的任務(wù)被不斷插入，這樣，低優(yōu)先級(jí)的任務(wù)就會(huì)有“餓死”的風(fēng)險(xiǎn)。
對(duì)于這種情況，我們?cè)谙M(fèi)的時(shí)候，可以考慮給每一個(gè)優(yōu)先級(jí)隊(duì)列分配一個(gè)權(quán)重，高優(yōu)先級(jí)的隊(duì)列有更大的概率被消費(fèi)，低優(yōu)先級(jí)的概率相對(duì)較小。感興趣的朋友們，可以自己去實(shí)現(xiàn)一下。
小結(jié)
本文和大家討論了優(yōu)先級(jí)隊(duì)列在golang中的一種實(shí)現(xiàn)方案，里面應(yīng)用到了切片、map、互斥鎖、管道等諸多golang特性，可以說是一個(gè)非常典型的案例。其實(shí)，優(yōu)先級(jí)隊(duì)列在實(shí)際的業(yè)務(wù)場(chǎng)景中使用廣泛，其實(shí)現(xiàn)方式也不止一種，我們需要根據(jù)實(shí)際的需求，選擇最優(yōu)解。
到此這篇關(guān)于golang優(yōu)先級(jí)隊(duì)列實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)golang優(yōu)先級(jí)隊(duì)列實(shí)現(xiàn)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
GoFrame通用類型變量gvar與interface基本使用對(duì)比
這篇文章主要為大家介紹了GoFrame通用類型變量gvar與interface基本使用對(duì)比，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-06-06
Go語(yǔ)言實(shí)現(xiàn)AzDG可逆加密算法實(shí)例
這篇文章主要介紹了Go語(yǔ)言實(shí)現(xiàn)AzDG可逆加密算法,實(shí)例分析了AzDG可逆加密算法的實(shí)現(xiàn)技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-02-02
這篇文章主要介紹了在Mac OS上安裝Go語(yǔ)言編譯器的方法,Docker的興起使得Go近來人氣大幅攀升,需要的朋友可以參考下2015-10-10
Golang String字符串類型轉(zhuǎn)Json格式
本文主要介紹了Golang String字符串類型轉(zhuǎn)Json格式的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-05-05
?Go?語(yǔ)言實(shí)現(xiàn)?HTTP?文件上傳和下載
這篇文章主要介紹了Go語(yǔ)言實(shí)現(xiàn)HTTP文件上傳和下載，文章圍繞主題展開詳細(xì)的內(nèi)容戒殺，具有一定的參考價(jià)值，需要的小伙伴可以參考一下2022-09-09
在Golang中,線程池和協(xié)程池是非常常見且重要的概念,它們可以提高應(yīng)用程序的并發(fā)處理能力和性能,減少資源的浪費(fèi),本文就來介紹一下Golang線程池與協(xié)程池的使用,感興趣的可以了解一下2024-04-04
這篇文章主要介紹了Golang截取字符串方法，文中介紹了使用rune函數(shù)和utf包以及range遍歷的方式，熟練掌握這些可以幫助我們更方便地處理字符串，提高編程效率和代碼質(zhì)量，感興趣的同學(xué)可以參考下文2023-05-05
這篇文章主要介紹了從源碼深入理解golang?RWMutex讀寫鎖操作,本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2023-05-05
Map是一個(gè)強(qiáng)大而又有趣的工具，它可以幫助我們高效地存儲(chǔ)和操作鍵值對(duì)數(shù)據(jù)，本文主要介紹了Go語(yǔ)言中Map的各種操作，包括增加、查找、刪除、遍歷等，具有一定的參考價(jià)值，感興趣的可以了解一下2023-08-08
使用Go?goroutine實(shí)現(xiàn)并發(fā)的Clock服務(wù)
這篇文章主要為大家詳細(xì)介紹了如何使用Go?goroutine實(shí)現(xiàn)并發(fā)的Clock服務(wù)，文中的示例代碼講解詳細(xì)，感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2023-06-06