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

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

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