当前位置: 代码迷 >> 综合 >> go并发协程示例
  详细解决方案

go并发协程示例

热度:76   发布时间:2024-02-06 17:43:23.0

如何用go写并发协程呢?来来来,有代码有真相

package mainimport "fmt"
import "time"
import "runtime"
import "sync/atomic"var runningMultiGoNum int64func  main() {//定时器,防止协程执行超时阻塞进程timeOuteRec := 10timeout     := time.Millisecond * time.Duration(timeOuteRec)tk := time.NewTicker(timeout)defer tk.Stop()chn := make(chan struct{string})go func(ch chan struct{string},txt string) {//原子操作atomic.AddInt64(&runningMultiGoNum, 1)// panic 处理if err := recover(); err != nil {stack := make([]byte, 8192)stack = stack[:runtime.Stack(stack, false)]fmt.Printf("multi_call panic:%v\n%s", err, stack)}atomic.AddInt64(&runningMultiGoNum, -1)//todo actionch<- struct{ string }{string: txt}}(chn,"Hello World")for{select {case s1:= <-chn:fmt.Println(s1.string)case <-tk.C:fmt.Println("exec over")return;}}
}

 

  相关解决方案