Thread-Per-Message Pattern，預備...發射！

在 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 秒