package main

import (
	"fmt"
	"time"
)

func main() {
	c := make(chan struct{})
	go func() {
		fmt.Println("業(yè)務(wù)處理~~~")
		time.Sleep(2 * time.Second)
		fmt.Println("業(yè)務(wù)處理完成~~~")
		close(c) // 關(guān)閉channel，通知工作完成
	}()

	<-c // 阻塞等待channel關(guān)閉
	fmt.Println("處理其他業(yè)務(wù)~~~")
}

package main

import (
	"fmt"
	"strconv"
	"sync"
	"time"
)

func main() {
	var wg sync.WaitGroup //控制并發(fā)組

	doWork := func(i int) {
        // wg.Done(): 表示一個(gè)事件已經(jīng)完成。它等價(jià)于 wg.Add(-1)，但更明確地表達(dá)了“完成一個(gè)任務(wù)”的意圖，并且在使用上更安全，因?yàn)樗粫?huì)導(dǎo)致計(jì)數(shù)變?yōu)樨?fù)數(shù)（如果已經(jīng)到達(dá)零，則會(huì)panic）。
		defer wg.Done() // 當(dāng)函數(shù)返回時(shí)，通知WaitGroup一個(gè)操作已完成相當(dāng)于wg.Add(-1)
		fmt.Println("處理業(yè)務(wù)~~~" + strconv.Itoa(i))
		time.Sleep(2 * time.Second)
		fmt.Println("業(yè)務(wù)處理完成~~~" + strconv.Itoa(i))
	}

	for i := 0; i < 5; i++ {
		wg.Add(1)    // 增加WaitGroup的計(jì)數(shù)器
		go doWork(i) // 啟動(dòng)一個(gè)goroutine做工作
	}
	//主goroutine調(diào)用wg.Wait()，直到所有啟動(dòng)的goroutines都通過調(diào)用wg.Done()通知它們已經(jīng)完成工作
	wg.Wait() // 阻塞，直到WaitGroup的計(jì)數(shù)器為0
	fmt.Println("所有業(yè)務(wù)處理完成~~~")
}

package main

import (
	"fmt"
	"sync"
	"time"
)

func main() {
	var mtx sync.Mutex         //創(chuàng)建互斥鎖
	cond := sync.NewCond(&mtx) //使用mtx作為底層互斥鎖
	ready := false

	// 啟動(dòng)一個(gè) goroutine 來改變條件變量 ready 的值，并通知 cond。
	go func() {
		fmt.Println("循環(huán)跟goroutine是go內(nèi)部決定先調(diào)度的--------------------goroutine--------------------")
		time.Sleep(3 * time.Second)
		mtx.Lock() //使用互斥鎖
		ready = true
		cond.Signal() // 喚醒至少一個(gè)等待的 goroutine
		mtx.Unlock()  //解鎖
	}()

	mtx.Lock() // 鎖定互斥鎖，準(zhǔn)備進(jìn)入條件等待
	for !ready {
		fmt.Println("循環(huán)跟goroutine是go內(nèi)部決定先調(diào)度的--------------------阻塞--------------------")
		cond.Wait() // 阻塞，直到 cond.Signal() 被調(diào)用
		//mtx.Unlock()
	}
	mtx.Unlock() // 解鎖互斥鎖，繼續(xù)執(zhí)行（此處mtx.Unlock()在for循環(huán)里面阻塞等待完成后也可以，也可以沒有，因?yàn)橹骶€程會(huì)結(jié)束,但如果后續(xù)還需要獲取互斥鎖則必須要釋放否則報(bào)錯(cuò)）

	fmt.Println("準(zhǔn)備繼續(xù)~~~")
}

package main

import "sync"

func main() {
	var wg sync.WaitGroup
	wg.Add(1)
	wg.Wait()
}

package main

func main() {
	select{}
}

package main

func main() {
	for {}
}

package main

import "sync"

func main() {
	var m sync.Mutex
	m.Lock()
}

package main

import (
	"os"
	"os/signal"
	"syscall"
)

func main() {
	sig := make(chan os.Signal, 2)
	//syscall.SIGTERM 是默認(rèn)的終止進(jìn)程信號(hào)，通常由服務(wù)管理器（如systemd、supervisor等）發(fā)送來請(qǐng)求程序正常終止。
	//syscall.SIGINT 是中斷信號(hào)，一般由用戶按下Ctrl+C鍵觸發(fā)，用于請(qǐng)求程序中斷執(zhí)行
	signal.Notify(sig, syscall.SIGTERM, syscall.SIGINT)
	<-sig
}

package main

import (
	"os"
	"os/signal"
	"syscall"
	"time"
)

func main() {
	sig := make(chan os.Signal, 2)
	//syscall.SIGTERM 是默認(rèn)的終止進(jìn)程信號(hào)，通常由服務(wù)管理器（如systemd、supervisor等）發(fā)送來請(qǐng)求程序正常終止。
	//syscall.SIGINT 是中斷信號(hào)，一般由用戶按下Ctrl+C鍵觸發(fā)，用于請(qǐng)求程序中斷執(zhí)行
	signal.Notify(sig, syscall.SIGTERM, syscall.SIGINT)

	go func() {
		time.Sleep(10 * time.Second)
		sig <- syscall.SIGTERM
	}()

	go func() {
		time.Sleep(5 * time.Second)
		sig <- syscall.SIGINT
	}()

	<-sig
}

package main

func main() {
	c := make(chan struct{})
	<-c
}

package main

func main() {
	var c chan struct{} //nil channel
	<-c
}