package main
 
import (
    "fmt"
    "time"
    "sync"
)
 
var 卷紙 int
var m sync.Mutex
var wg sync.WaitGroup
 
func 上廁所(姓名 string){
    m.Lock()
    defer func(){
        m.Unlock()
        wg.Done()
    }()
    fmt.Printf("%s 進(jìn)到廁所\t",姓名)
    if 卷紙 >= 1 {  // 進(jìn)到廁所第一件事是看還有沒(méi)有紙
        fmt.Printf("正在拉屎中...\n")
        time.Sleep(time.Second)
        卷紙 -= 1
        fmt.Printf("%s 已用完廁所，正在離開(kāi)\n",姓名)
        return
    }
    fmt.Printf("發(fā)現(xiàn)紙用完了，無(wú)奈先離開(kāi)廁所\n")
}
 
func 加廁紙(){
    m.Lock()
    defer func(){
        m.Unlock()
        wg.Done()
    }()
    fmt.Printf("公園管理員 進(jìn)到廁所\t")
    if 卷紙 <= 0 { // 管理員進(jìn)到廁所是看紙有沒(méi)有用完
        fmt.Printf("公園管理員 正在加新紙...\n")
        time.Sleep(time.Millisecond*500)
        卷紙 = 5
        fmt.Printf("公園管理員 已加上新廁紙，正在離開(kāi)\n")
    }else{
        fmt.Printf("發(fā)現(xiàn)紙還沒(méi)用完，先離開(kāi)廁所\n")
    }
}
 
func main() {
    卷紙 = 5 // 廁所一開(kāi)始就準(zhǔn)備好了一卷紙，長(zhǎng)度5米
    要排隊(duì)上廁所的人 := [...]string{"老王","小李","老張","小劉","阿明","欣欣","西西","芳芳"}
    for _,誰(shuí) := range 要排隊(duì)上廁所的人 {
        wg.Add(1)
        go 上廁所(誰(shuí))
    }
    wg.Add(1)
    go 加廁紙()
    wg.Wait()
}
 
/*
輸出（由于協(xié)程執(zhí)行順序的不可預(yù)測(cè)性，因此每次輸出的順序都可能不一樣）：
 
公園管理員 進(jìn)到廁所     發(fā)現(xiàn)紙還沒(méi)用完，先離開(kāi)廁所
阿明 進(jìn)到廁所   正在拉屎中...
阿明 已用完廁所，正在離開(kāi)
老王 進(jìn)到廁所   正在拉屎中...
老王 已用完廁所，正在離開(kāi)
小劉 進(jìn)到廁所   正在拉屎中...
小劉 已用完廁所，正在離開(kāi)
小李 進(jìn)到廁所   正在拉屎中...
小李 已用完廁所，正在離開(kāi)
老張 進(jìn)到廁所   正在拉屎中...
老張 已用完廁所，正在離開(kāi)
欣欣 進(jìn)到廁所   發(fā)現(xiàn)紙用完了，無(wú)奈先離開(kāi)廁所
芳芳 進(jìn)到廁所   發(fā)現(xiàn)紙用完了，無(wú)奈先離開(kāi)廁所
西西 進(jìn)到廁所   發(fā)現(xiàn)紙用完了，無(wú)奈先離開(kāi)廁所
*/

package main
 
import (
    "fmt"
    "sync"
    "time"
)
 
var (
    卷紙    int
    m     sync.Mutex
    wg    sync.WaitGroup
    廁所的排隊(duì) chan string
)
 
func 上廁所(姓名 string) {
    m.Lock() // 該語(yǔ)句的調(diào)用只說(shuō)明本執(zhí)行體（可理解成該姓名所指的那個(gè)人）加入到了廁所資源的爭(zhēng)搶組中；
             // 而該語(yǔ)句的完成調(diào)用，才代表了從爭(zhēng)搶組中脫穎而出，搶到了廁所；在完成調(diào)用之前，會(huì)一直阻塞在這里（可理解為這個(gè)人正在爭(zhēng)搶中）
    defer func() {
        m.Unlock()
        wg.Done()
    }()
    fmt.Printf("%s 進(jìn)到廁所\t", 姓名)
    if 卷紙 >= 1 { // 進(jìn)到廁所第一件事是看還有沒(méi)有紙
        fmt.Printf("正在拉屎中...\n")
        time.Sleep(time.Second)
        卷紙 -= 1
        fmt.Printf("%s 已用完廁所，正在離開(kāi)\n", 姓名)
        return
    }
    fmt.Printf("發(fā)現(xiàn)紙用完了，無(wú)奈先離開(kāi)廁所\n")
    廁所的排隊(duì) <- 姓名 // 再次加入廁所排隊(duì)，期望下次可以成功如廁
}
 
func 加廁紙() {
    m.Lock()
    defer m.Unlock()
    fmt.Printf("公園管理員 進(jìn)到廁所\t")
    if 卷紙 <= 0 { // 管理員進(jìn)到廁所是看紙有沒(méi)有用完
        fmt.Printf("公園管理員 正在加新紙...\n")
        time.Sleep(time.Millisecond * 500)
        卷紙 = 5
        fmt.Printf("公園管理員 已加上新廁紙，正在離開(kāi)\n")
    } else {
        fmt.Printf("發(fā)現(xiàn)紙還沒(méi)用完，先離開(kāi)廁所\n")
    }
}
 
func main() {
    卷紙 = 5                                                                // 廁所一開(kāi)始就準(zhǔn)備好了一卷紙，長(zhǎng)度5米
    要上廁所的人 := [...]string{"老王", "小李", "老張", "小劉", "阿明", "欣欣", "西西", "芳芳"} // 這里只是舉幾個(gè)人名例子，假設(shè)此處有源源不斷的人去上廁所（讀者可以隨意改造人名來(lái)源）
    廁所的排隊(duì) = make(chan string, len(要上廁所的人))
    for _, 誰(shuí) := range 要上廁所的人 {
        廁所的排隊(duì) <- 誰(shuí)
    }
    go func() { // 在這個(gè)執(zhí)行體中，會(huì)不斷從 廁所排隊(duì) 中把人加入到 對(duì)廁所資源的爭(zhēng)搶組中
        for 誰(shuí) := range 廁所的排隊(duì) {
            wg.Add(1)
            go 上廁所(誰(shuí))
        }
    }()
    wg.Add(1)
    go func() { // 在這個(gè)執(zhí)行體中，代表公園管理員的個(gè)人時(shí)間線，他會(huì)每隔一段時(shí)間去加入爭(zhēng)搶組進(jìn)到廁所，檢查紙還有沒(méi)有
        for {
            time.Sleep(time.Millisecond * 1200)
            加廁紙()
        }
    }()
    wg.Wait()
}
 
/*
輸出：
 
老王 進(jìn)到廁所   正在拉屎中...
老王 已用完廁所，正在離開(kāi)
芳芳 進(jìn)到廁所   正在拉屎中...
芳芳 已用完廁所，正在離開(kāi)
阿明 進(jìn)到廁所   正在拉屎中...
阿明 已用完廁所，正在離開(kāi)
小劉 進(jìn)到廁所   正在拉屎中...
小劉 已用完廁所，正在離開(kāi)
欣欣 進(jìn)到廁所   正在拉屎中...
欣欣 已用完廁所，正在離開(kāi)
小李 進(jìn)到廁所   發(fā)現(xiàn)紙用完了，無(wú)奈先離開(kāi)廁所
老張 進(jìn)到廁所   發(fā)現(xiàn)紙用完了，無(wú)奈先離開(kāi)廁所
西西 進(jìn)到廁所   發(fā)現(xiàn)紙用完了，無(wú)奈先離開(kāi)廁所
公園管理員 進(jìn)到廁所     公園管理員 正在加新紙...
公園管理員 已加上新廁紙，正在離開(kāi)
西西 進(jìn)到廁所   正在拉屎中...
西西 已用完廁所，正在離開(kāi)
小李 進(jìn)到廁所   正在拉屎中...
小李 已用完廁所，正在離開(kāi)
老張 進(jìn)到廁所   正在拉屎中...
老張 已用完廁所，正在離開(kāi)
公園管理員 進(jìn)到廁所     發(fā)現(xiàn)紙還沒(méi)用完，先離開(kāi)廁所
公園管理員 進(jìn)到廁所     發(fā)現(xiàn)紙還沒(méi)用完，先離開(kāi)廁所
公園管理員 進(jìn)到廁所     發(fā)現(xiàn)紙還沒(méi)用完，先離開(kāi)廁所
*/

package main
 
import (
    "fmt"
    "math"
    "strconv"
    "sync"
    "time"
)
 
var (
    卷紙   int
    m    sync.Mutex
    cond = sync.NewCond(&m)
)
 
func 上廁所(姓名 string) {
    m.Lock() // 該語(yǔ)句的調(diào)用只說(shuō)明本執(zhí)行體（可理解成該姓名所指的那個(gè)人）加入到了廁所資源的爭(zhēng)搶組中；
             // 而該語(yǔ)句的完成調(diào)用，才代表了從爭(zhēng)搶組中脫穎而出，搶到了廁所；在完成調(diào)用之前，會(huì)一直阻塞在這里（可理解為這個(gè)人正在爭(zhēng)搶中）
    defer m.Unlock()
    fmt.Printf("%s 進(jìn)到廁所\t", 姓名)
    for 卷紙 < 1 { // 進(jìn)到廁所第一件事是看還有沒(méi)有紙
        fmt.Printf("發(fā)現(xiàn)紙用完了，先離開(kāi)廁所在附近歇息等待信號(hào)\n")
        cond.Wait() // 該語(yǔ)句的調(diào)用 相當(dāng)于調(diào)用了 m.Unlock() 也就是退出了爭(zhēng)搶組，而是先歇著等待紙加上的信號(hào)；
                    // 當(dāng)收到紙加上的信號(hào)后，該語(yǔ)句會(huì)自動(dòng)執(zhí)行 m.Lock()，也就是會(huì)重新加入到廁所的爭(zhēng)搶組中；
                    // 該語(yǔ)句的完成調(diào)用說(shuō)明已經(jīng)再次成功爭(zhēng)搶到了廁所；
        fmt.Printf("%s 等到了廁紙已加的信號(hào)，并去再次搶到了廁所\t", 姓名)
    }
    fmt.Printf("正在拉屎中...\n")
    time.Sleep(time.Second)
    卷紙 -= 1
    fmt.Printf("%s 已用完廁所\t", 姓名)
    if 卷紙 < 1 { // 注意這里：在他用完廁所離開(kāi)前，他需要看是不是紙已經(jīng)用完了，如果用完了，就按下紙用盡的報(bào)警按鈕，給公園管理員發(fā)送信號(hào)
        cond.Broadcast() // 想想，這里為什么不用 Signal() ？因?yàn)?Signal 只能通知到一個(gè)等待者，這樣就有可能通知不到 公園管理員。可以試著把這里換成 Signal() 試下
        fmt.Printf("發(fā)現(xiàn)廁紙已用完，并按下了報(bào)警\t")
    }
    fmt.Printf("正在離開(kāi)廁所\n")
}
 
func 加廁紙() {
    m.Lock()
    defer m.Unlock()
    fmt.Printf("公園管理員 進(jìn)到廁所\t")
    for 卷紙 > 0 { // 管理員進(jìn)到廁所是看紙有沒(méi)有用完
        fmt.Printf("發(fā)現(xiàn)紙還沒(méi)用完，先離開(kāi)廁所在等紙用盡的報(bào)警消息\n")
        cond.Wait() // 如果紙沒(méi)用完，就先去干其他工作，等紙用盡的報(bào)警消息
        fmt.Printf("公園管理員 等到了紙用盡的報(bào)警消息，并再次搶到了廁所\n")
    }
    fmt.Printf("公園管理員 正在加新紙...\n")
    time.Sleep(time.Millisecond * 500)
    卷紙 = 5
    cond.Broadcast() // 注意：公園管理員加完新紙后，要通過(guò)喇叭喊一聲 “紙已加上” 的消息通知所有 因沒(méi)紙而等待上廁所的人
    fmt.Printf("公園管理員 已加上新廁紙，并通過(guò)喇叭通知了該消息，并正在離開(kāi)廁所\n")
}
 
func main() {
    卷紙 = 5  // 廁所一開(kāi)始就準(zhǔn)備好了一卷紙，長(zhǎng)度5米
    要上廁所的人 := [...]string{"老王", "小李", "老張", "小劉", "阿明", "欣欣", "西西", "芳芳"} // 上廁所的人名模板
    go func() { // 在這個(gè)執(zhí)行體中，代表廁所及廁所隊(duì)列的時(shí)間線，廁所永遠(yuǎn)運(yùn)營(yíng)下去
        for i := 0; i < math.MaxInt; i++ { // 此循環(huán)通過(guò)編號(hào)加上上面的姓名模板來(lái) 創(chuàng)建源源不斷 上廁所的人
            for _, 人名模板 := range 要上廁所的人 {
                誰(shuí) := 人名模板 + strconv.Itoa(i)
                go 上廁所(誰(shuí))
                time.Sleep(time.Millisecond * 500) // 平均每半秒有一個(gè)人去上廁所
            }
            fmt.Printf("\n====================>> 屏幕停止輸出后，請(qǐng)按Enter鍵繼續(xù) <<====================\n\n")
            fmt.Scanln()
        }
    }()
    go func() { // 在這個(gè)執(zhí)行體中，代表公園管理員的個(gè)人時(shí)間線，管理員永不退休
        for {
            // 注意：相比上個(gè)版本，此處不用再加 Sleep 函數(shù)了，因?yàn)?加廁紙() 函數(shù)中的 cond.Wait() 會(huì)在有紙的時(shí)候等待信號(hào)
            加廁紙()
        }
    }()
    end := make(chan bool)
    <-end
}
 
/*
輸出：
 
公園管理員 進(jìn)到廁所     發(fā)現(xiàn)紙還沒(méi)用完，先離開(kāi)廁所在等紙用盡的報(bào)警消息
老王0 進(jìn)到廁所  正在拉屎中...
老王0 已用完廁所        正在離開(kāi)廁所
小李0 進(jìn)到廁所  正在拉屎中...
小李0 已用完廁所        正在離開(kāi)廁所
老張0 進(jìn)到廁所  正在拉屎中...
老張0 已用完廁所        正在離開(kāi)廁所
小劉0 進(jìn)到廁所  正在拉屎中...
小劉0 已用完廁所        正在離開(kāi)廁所
阿明0 進(jìn)到廁所  正在拉屎中...
 
====================>> 屏幕停止輸出后，請(qǐng)按Enter鍵繼續(xù) <<====================
 
阿明0 已用完廁所        發(fā)現(xiàn)廁紙已用完，并按下了報(bào)警    正在離開(kāi)廁所
欣欣0 進(jìn)到廁所  發(fā)現(xiàn)紙用完了，先離開(kāi)廁所在附近歇息等待信號(hào)
西西0 進(jìn)到廁所  發(fā)現(xiàn)紙用完了，先離開(kāi)廁所在附近歇息等待信號(hào)
芳芳0 進(jìn)到廁所  發(fā)現(xiàn)紙用完了，先離開(kāi)廁所在附近歇息等待信號(hào)
公園管理員 等到了紙用盡的報(bào)警消息，并再次搶到了廁所
公園管理員 正在加新紙...
公園管理員 已加上新廁紙，并通過(guò)喇叭通知了該消息，并正在離開(kāi)廁所
公園管理員 進(jìn)到廁所     發(fā)現(xiàn)紙還沒(méi)用完，先離開(kāi)廁所在等紙用盡的報(bào)警消息
欣欣0 等到了廁紙已加的信號(hào)，并去再次搶到了廁所  正在拉屎中...
欣欣0 已用完廁所        正在離開(kāi)廁所
芳芳0 等到了廁紙已加的信號(hào)，并去再次搶到了廁所  正在拉屎中...
芳芳0 已用完廁所        正在離開(kāi)廁所
西西0 等到了廁紙已加的信號(hào)，并去再次搶到了廁所  正在拉屎中...
西西0 已用完廁所        正在離開(kāi)廁所
 
老王1 進(jìn)到廁所  正在拉屎中...
老王1 已用完廁所        正在離開(kāi)廁所
小李1 進(jìn)到廁所  正在拉屎中...
小李1 已用完廁所        發(fā)現(xiàn)廁紙已用完，并按下了報(bào)警    正在離開(kāi)廁所
老張1 進(jìn)到廁所  發(fā)現(xiàn)紙用完了，先離開(kāi)廁所在附近歇息等待信號(hào)
公園管理員 等到了紙用盡的報(bào)警消息，并再次搶到了廁所
公園管理員 正在加新紙...
公園管理員 已加上新廁紙，并通過(guò)喇叭通知了該消息，并正在離開(kāi)廁所
公園管理員 進(jìn)到廁所     發(fā)現(xiàn)紙還沒(méi)用完，先離開(kāi)廁所在等紙用盡的報(bào)警消息
小劉1 進(jìn)到廁所  正在拉屎中...
小劉1 已用完廁所        正在離開(kāi)廁所
阿明1 進(jìn)到廁所  正在拉屎中...
 
====================>> 屏幕停止輸出后，請(qǐng)按Enter鍵繼續(xù) <<====================
*/