三言兩語說透設計模式的藝術-簡單工廠模式
一、寫在前面工廠模式是最常見的一種創建型設計模式，通常說的工廠模式指的是工廠方法模式，是使用頻率最高的工廠模式。簡單工廠模式又稱為靜態工廠方法模式，不屬于GoF 23種設計
在這個系列的最后兩篇文章中，我們討論了來自sync包的Mutex和RWMutex。當我們希望只有一個Goroutine能夠獨占地訪問共享數據時，這兩個結構非常有用。
然而，在現實生活中，有些用例需要允許多個用戶同時訪問共享資源。這個數量可以很大，也可以很小，但必須始終是有限的。例如，一個容納60000人的體育場在任何時候都不應容納超過這個數量的人。或者，在機場，無論乘客隊列有多長，同時允許辦理登機手續的最大乘客數量就是開放柜臺的數量。在計算機科學中，這種并發訪問的用例是用信號量（Semaphore）來建模的。在本文中，我將通過可視化的方式解釋信號量（Semaphore）的工作原理。我還將與您分享如何在Golang中使用通道來簡單實現信號量（Semaphore）的方法。
1*rNpdTpCmhFyRV0FULxkBvQ.png
片刻之后，Partier和Swimmer也想去游泳。此時只有一個泳道可用。只有其中一個可以獲得泳道，另一個必須等待。當M個Goroutine競爭N（N < M）個槽位時，我們不能保證誰會贏得這個“競爭”。在這種情況下，當M=2和N=1時，假設Swimmer贏了。
1*hMzIXmAgnnqLXUhD8LTIOQ.png
Swimmer非常擅長這項運動。他迅速完成了他的輪次，并迅速釋放了泳道，使其可用于Partier。與此同時，Candier仍然在她的泳道上游泳。
1*wtiF0BMWk8KY144wVXSgOg.png
Stringer想去游泳，但兩個泳道目前都被占用。他別無選擇，只能等待。他不知道也不關心哪一條泳道會先可用。
1*jxskbQzVSTQLLp6Lo3nGnQ.png
假設Partier在這項運動中也比Candier更有天賦。盡管在Candier之后開始，但仍然比她早完成。Partier釋放了他的泳道，使其可用于Stringer。
1*kiRY3yaZ1GUjxu75DLGP5g.png
不久后，Candier完成并釋放了她的泳道。泳道變得可用，但沒有人試圖占用它，它仍然可用。
最后，Stringer完成了他的輪次。他釋放了他的泳道，使兩個泳道都可用。
1*Xc6fPx1gWLDIQYLv_yL9ww.png
在技術面試中，Semaphore這個術語可能聽起來有點嚇人。然而，正如你在上面的插圖中所看到的，它是非常容易理解的。事實上，我曾幾次在面試中問過我的面試者關于Semaphore的問題。例如，設計一個在黑色星期五上線的虛擬商店。有很多顧客想進去，但商店最多只能容納N個顧客。每個顧客進去后沒有時間限制，他/她可以一整天待在店里，也可以一進去就離開。當已經有N個顧客在里面時，后來的顧客必須排隊等候，直到有人離開。當然，有很多解決這個問題的方法，其中沒有一個是對或錯的。我希望這篇文章為您提供了處理N個并發訪問問題的另一種工具。
辦理登機手續柜臺、體育場的座位以及計算機資源，如CPU、內存和網絡，有一個共同點：它們都是有限的。通常，控制應用程序資源使用是一個好主意。我曾在我的一個應用程序中使用Semaphore來限制一次只能有限數量的并發資源密集型Goroutine。這也可以通過一個包含N個Goroutine的池來解決。然而，由于我們的并發工作負載不是均勻分布在時間上的，它可能在0和N之間的任何位置，所以我們發現Semaphore是一個更好的選擇。
請注意，Semaphore并不像sync.Mutex一樣作為內置組件提供。相反，Go團隊將其作為擴展提供。將其添加到項目中非常簡單：go get golang.org/x/sync。
package mainimport ( "context" "golang.org/x/sync/semaphore" "log" "time")func main() { pool := semaphore.NewWeighted(2) go swim("Candier", pool) go swim("Swimmer", pool) go swim("Partier", pool) go swim("Stringer", pool) time.Sleep(5 * time.Second) // For brevity, better use sync.WaitGroup log.Println("Main: Done, shutting down")}func swim(name string, pool *semaphore.Weighted) { log.Printf("%v: I want to swim/n", name) // In real applications, pass in your context such as HTTP request context ctx := context.Background() // We can also Acquire/Release more than 1 // when the workloads consume different amount of resources if err := pool.Acquire(ctx, 1); err != nil { log.Printf("%v: Ops, something went wrong! I cannot acquire a lane/n", name) return } log.Printf("%v: I got a lane, I'm swimming/n", name) time.Sleep(time.Second) log.Printf("%v: I'm done. Releasing my lane/n", name) pool.Release(1)}如果您不想將golang.org/x/sync/semaphore添加到項目中，使用通道自己實現Semaphore也相當簡單。
type Semaphore struct { ch chan bool}func NewSemaphore(weight int) *Semaphore { return &Semaphore{ ch: make(chan bool, weight), }}func (s *Semaphore) Acquire() { s.ch <- true}func (s *Semaphore) Release() { <-s.ch}}本文鏈接：http://www.tebozhan.com/showinfo-26-12383-0.htmlGo 并發可視化解釋 - Semaphore
聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
上一篇： 使用Spring Boot和Next.js創建全棧應用指南
下一篇： Python多線程詳細體驗
Copyright ? 2016-2023 天津谷騏科技有限公司 版權所有 sitemap.xml
違法及侵權請聯系：2376512515@qq.com 津ICP備18001702號
津公網安備 12010102000574號