iT邦幫忙

2021 iThome 鐵人賽

DAY 5
2
Software Development

Hey! Go Design Patterns系列 第 5

DAY 5:Thread-Per-Message Pattern,預備...發射!

  • 分享至 

  • xImage
  •  

2023/04/05 更新: 為了避免本文章散落在不同網站,之後統一由部落格更新,再麻煩從部落格查看~

在 DAY 2~DAY 4 我們使用到了 goroutine、lock、channel,主要目標在保護併發下的資料避免 race condition,接下來會以提高執行效率為討論重點。

什麼是 Thread-Per-Message Pattern?

每一個 message 開啟一個 goroutine 來運行

如果有多個 task 需要運行,每個 task 的執行時間過長,比如 IO 或者是複雜的運算,那一個一個執行 task 是相當浪費時間的,只要 task 沒有執行順序的需求,可以將所有 task 都同時執行。

並且 Thread-Per-Message Pattern 是用在不需要 goroutine 回傳值的情境中,如果需要回傳值,可以使用 Future Pattern,接下來的文章會再介紹。

問題情境

設計一個推播新聞系統,會將新的新聞直接推播出去,我們希望推播系統效率要高。

相關的 code 在Github - go-design-patterns

實作有問題的系統如下:

package main

import (
	"fmt"
	"time"
)

func PushNews(news string, startTime time.Time) {
	time.Sleep(time.Duration(3 * time.Second)) //模擬推播運行的時間
	fmt.Printf("%s cost %s\n", news, time.Since(startTime))
}

func main() {
	start := time.Now()
	allNews := []string{
		"中秋節來了",
		"記得",
		"不要戶外烤肉~",
	}
	for _, news := range allNews {
		PushNews(news, start)
	}
	fmt.Printf("cost %s", time.Since(start))
}

由於每則新聞都是一則一則推播,所以耗時了約 9 秒

解決方式

PushNews()加上go就可以啟動 goroutine 來推播

package main

import (
	"fmt"
	"time"
)

func PushNews(news string, startTime time.Time) {
	time.Sleep(time.Duration(3 * time.Second)) //模擬推播運行的時間
	fmt.Printf("%s cost %s\n", news, time.Since(startTime))
}

func main() {
	start := time.Now()
	allNews := []string{
		"中秋節來了",
		"記得",
		"不要戶外烤肉~",
	}
	for _, news := range allNews {
		go PushNews(news, start)
	}
	time.Sleep(10 * time.Second) //等待goroutine執行完畢
}

由於是同時推播,所以推播只花了 3 秒


上一篇
DAY 4:Guarded Suspension Pattern,你不會死的,因為我會保護你
下一篇
DAY 6:Feature Pattern,我把未來託付給你了!
系列文
Hey! Go Design Patterns30
圖片
  直播研討會
圖片
{{ item.channelVendor }} {{ item.webinarstarted }} |
{{ formatDate(item.duration) }}
直播中

尚未有邦友留言

立即登入留言