func GetGID() uint64 {
    b := make([]byte, 64)
    b = b[:runtime.Stack(b, false)]
    b = bytes.TrimPrefix(b, []byte("goroutine "))
    b = b[:bytes.IndexByte(b, ' ')]
    n, _ := strconv.ParseUint(string(b), 10, 64)
    return n
}

import (
  "fmt"
  "runtime"
  "sync"
)
var (
  count int32
  wg  sync.WaitGroup
)
func main() {
  wg.Add(2)
  go incCount()
  go incCount()
  wg.Wait()
  fmt.Println(count)
}
func incCount() {
  defer wg.Done()
  for i := 0; i < 2; i++ {
    value := count
    runtime.Gosched()
    value++
    count = value
  }
}

==================
WARNING: DATA RACE
Read at 0x000000619cbc by goroutine 8:
 main.incCount()
   D:/code/src/main.go:25 +0x80// goroutine 8 在代码 25 行读取共享资源value := count
Previous write at 0x000000619cbc by goroutine 7:
 main.incCount()
   D:/code/src/main.go:28 +0x9f// goroutine 7 在代码 28行修改共享资源count=value
Goroutine 8 (running) created at:
 main.main()
   D:/code/src/main.go:17 +0x7e
Goroutine 7 (finished) created at:
 main.main()
   D:/code/src/main.go:16 +0x66//两个 goroutine 都是从 main 函数的 16、17 行通过 go 关键字启动的。
==================
4
Found 1 data race(s)

import (
  "fmt"
  "runtime"
  "sync"
  "sync/atomic"
)
var (
  counter int64
  wg   sync.WaitGroup
)
func main() {
  wg.Add(2)
  go incCounter(1)
  go incCounter(2)
  wg.Wait() //等待goroutine结束
  fmt.Println(counter)
}
func incCounter(id int) {
  defer wg.Done()
  for count := 0; count < 2; count++ {
    atomic.AddInt64(&counter, 1) //安全的对counter加1
    runtime.Gosched()
  }
}

import (
  "fmt"
  "sync"
  "sync/atomic"
  "time"
)
var (
  shutdown int64
  wg    sync.WaitGroup
)
func main() {
  wg.Add(2)
  go doWork("A")
  go doWork("B")
  time.Sleep(1 * time.Second)
  fmt.Println("Shutdown Now")
  atomic.StoreInt64(&shutdown, 1)
  wg.Wait()
}
func doWork(name string) {
  defer wg.Done()
  for {
    fmt.Printf("Doing %s Work\n", name)
    time.Sleep(250 * time.Millisecond)
    if atomic.LoadInt64(&shutdown) == 1 {
      fmt.Printf("Shutting %s Down\n", name)
      break
    }
  }
}
--output--
Doing A Work
Doing B Work
Doing B Work
Doing A Work
Doing A Work
Doing B Work
Doing B Work
Doing A Work//前8行顺序每次运行时都不一样
Shutdown Now
Shutting A Down
Shutting B Down//A和B都shut down后，由wg.Done()把计数器置0

func incCounter(id int) {
  defer wg.Done()
  for count := 0; count < 2; count++ {
    //同一时刻只允许一个goroutine进入这个临界区
    mutex.Lock()
    {
      value := counter
      runtime.Gosched()//退出当前goroutine，调度器会再次分配这个 goroutine 继续运行。
      value++
      counter = value
    }
    mutex.Unlock() //释放锁，允许其他正在等待的goroutine进入临界区
  }
}

import (
  "fmt"
  "time"
)
func main() {
  // 构建一个通道，这里有没有缓冲都可，因为是收了就发，无需阻塞等待
  ch := make(chan int)
  // 开启一个并发匿名函数
  go func() {
    // 从3循环到0
    for i := 3; i >= 0; i-- {
      // 发送3到0之间的数值
      ch <- i
      // 每次发送完时等待
      time.Sleep(time.Second)
    }
  }()
  // 遍历接收通道数据
  for data := range ch {
    // 打印通道数据
    fmt.Println(data)
    // 当遇到数据0时, 退出接收循环
    if data == 0 {
        break
    }
  }
}
--output--

ch := make(chan int)
// 声明一个只能写入数据的通道类型, 并赋值为ch
var chSendOnly chan<- int = ch
或
ch := make(chan<- int)
//声明一个只能读取数据的通道类型, 并赋值为ch
var chRecvOnly <-chan int = ch
或
ch := make(<-chan int)

// 这个示例程序展示如何用无缓冲的通道来模拟
// 2 个goroutine 间的网球比赛
package main
import (
  "fmt"
  "math/rand"
  "sync"
  "time"
)
// wg 用来等待程序结束
var wg sync.WaitGroup
func init() {
  rand.Seed(time.Now().UnixNano())
}
// main 是所有Go 程序的入口
func main() {
  // 创建一个无缓冲的通道
  court := make(chan int)
  // 计数加 2，表示要等待两个goroutine
  wg.Add(2)
  // 启动两个选手
  go player("Nadal", court)
  go player("Djokovic", court)
  // 发球
  court <- 1
  // 等待游戏结束
  wg.Wait()
}
// player 模拟一个选手在打网球
func player(name string, court chan int) {
  // 在函数退出时调用Done 来通知main 函数工作已经完成
  defer wg.Done()
  for {
    // 等待球被击打过来
    ball, ok := <-court
    if !ok {
      // 如果通道被关闭，我们就赢了
      fmt.Printf("Player %s Won\n", name)
      return
    }
    // 选随机数，然后用这个数来判断我们是否丢球
    n := rand.Intn(100)
    if n%13 == 0 {
      fmt.Printf("Player %s Missed\n", name)
      // 关闭通道，表示我们输了
      close(court)
      return
    }
    // 显示击球数，并将击球数加1
    fmt.Printf("Player %s Hit %d\n", name, ball)
    ball++
    // 将球打向对手，为啥这里是把ball发送到另一个go协程？
    //因为court无缓冲，此时另一个go协程正好在等待接收court内的值，所以此时转向另一个go协程代码
    court <- ball
  }
}

select {
  case <-chan1:
  // 如果chan1成功读到数据，则进行该case处理语句
  case chan2 <- 1:
  // 如果成功向chan2写入数据，则进行该case处理语句
  default:
  // 如果上面都没有成功，则进入default处理流程
}

func main() {
  ch := make(chan int)
  quit := make(chan bool)
  //新开一个协程
  go func() {
    for {
      select {
      case num := <-ch:
        fmt.Println("num = ", num)
      case <-time.After(3 * time.Second):
        fmt.Println("超时")
        quit <- true
      }
    }
  }() //别忘了()
  for i := 0; i < 5; i++ {
    ch <- i
    time.Sleep(time.Second)//主协程进入休眠状态，等待上面的go协程运行并进入阻塞等待状态，就这样来回运行，并通过chan通信
  }
  <-quit
  fmt.Println("程序结束")
}
--output--
num = 0
num = 1
num = 2
num = 3
num = 4
超时
程序结束