關(guān)于golang高并發(fā)的實(shí)現(xiàn)與注意事項(xiàng)說(shuō)明

package main
 
import (
 "fmt"
 "time"
)
 
func comFunc() {
 fmt.Println("This is a common function.")
}
 
func main() {
 go comFunc()
 time.Sleep(time.Second * 3)
}

package main
import (
 "fmt"
 "sync"
)
var waitGroup sync.WaitGroup
func Afunction(index int) {
 fmt.Println(index)
 waitGroup.Done() //任務(wù)完成，將任務(wù)隊(duì)列中的任務(wù)數(shù)量-1，其實(shí).Done就是.Add(-1)
}
 
func main() {
 for i := 0; i  10; i++ {
  waitGroup.Add(1) //每創(chuàng)建一個(gè)goroutine，就把任務(wù)隊(duì)列中任務(wù)的數(shù)量+1
  go Afunction(i)
 }
 waitGroup.Wait() //.Wait()這里會(huì)發(fā)生阻塞，直到隊(duì)列中所有的任務(wù)結(jié)束就會(huì)解除阻塞
}

package main
func main() {
 ch := make(chan int, 3)
 ch - 1
 ch - 1
 ch - 1
 ch - 1 //這一行操作就會(huì)發(fā)生阻塞，因?yàn)榍叭械姆湃霐?shù)據(jù)的操作已經(jīng)把channel填滿了
}
package main
func main() {
 ch := make(chan int, 3)
 -ch //這一行會(huì)發(fā)生阻塞，因?yàn)閏hannel才剛創(chuàng)建，是空的，沒(méi)有東西可以取出
}

ch := make(chan int)  //無(wú)緩沖的channel，同等于make(chan int, 0)
ch := make(chan int, 5) //一個(gè)緩沖區(qū)大小為5的channel

package main 
import (
 "fmt"
 "sync"
)
 
var waitGroup sync.WaitGroup //使用wg等待所有routine執(zhí)行完畢，并輸出相應(yīng)的提示信息
 
func AFunc(ch chan int) {
 waitGroup.Add(1)
FLAG:
 for {
  select {
  case val := -ch:
   fmt.Println(val)
   break FLAG
  }
 }
 waitGroup.Done()
 fmt.Println("WaitGroup Done")
}
 
func main() {
 
 ch := make(chan int) //無(wú)緩沖通道
 execMode := 0        //執(zhí)行模式 0：先啟動(dòng)并發(fā)，正常輸出100 1：后啟動(dòng)并發(fā)，發(fā)生死鎖
 switch execMode {
 case 0:
  go AFunc(ch)
  ch - 100
 case 1:
  ch - 100
  go AFunc(ch)
 }
 waitGroup.Wait()
 close(ch)
}

package main
import (
 "fmt"
 "sync"
)
var waitGroup sync.WaitGroup
func AFunc(ch chan int, putMode int) {
 val := -ch
 switch putMode {
 case 0:
  fmt.Printf("Vaule=%d\n", val)
 case 1:
  fmt.Printf("Vaule=%d\n", val)
  for i := 1; i = 5; i++ {
   ch - i * val
  }
 case 2:
  fmt.Printf("Vaule=%d\n", val)
  for i := 1; i = 5; i++ {
   -ch
  }
 }
 
 waitGroup.Done()
 fmt.Println("WaitGroup Done", val)
}
 
func main() {
 ch := make(chan int, 10)
 putMode := 0 //該模式下，能夠正常輸出所有數(shù)據(jù)
 //putMode := 1//當(dāng)放入速度遠(yuǎn)大于取數(shù)速度時(shí)，程序阻塞
 //putMode := 2//當(dāng)取數(shù)速度遠(yuǎn)大于放數(shù)速度時(shí)，程序阻塞
 for i := 0; i  1000; i++ {
  ch - i
  waitGroup.Add(1)
  go AFunc(ch, putMode)
 }
 waitGroup.Wait()
 close(ch)
}

package main
func main() {
 ch := make(chan int, 5)
 ch - 1
 ch - 1
 close(ch)
 ch - 1 //不能對(duì)關(guān)閉的channel執(zhí)行放入操作
        
        // 會(huì)觸發(fā)panic
}

package main
func main() {
 ch := make(chan int, 5)
 ch - 1
 ch - 1
 close(ch)
 -ch //只要channel還有數(shù)據(jù)，就可能執(zhí)行取出操作
 
        //正常結(jié)束
}

package main 
import "fmt" 
func main() {
 ch := make(chan int, 5)
 ch - 1
 ch - 1
 ch - 1
 ch - 1
 close(ch)  //如果執(zhí)行了close()就立即關(guān)閉channel的話，下面的循環(huán)就不會(huì)有任何輸出了
 for {
  data, ok := -ch
  if !ok {
   break
  }
  fmt.Println(data)
 }
 
 // 輸出：
 // 1
 // 1
 // 1
 // 1
 // 
 // 調(diào)用了close()后，只有channel為空時(shí)，channel才會(huì)真的關(guān)閉
}