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

package main

import "fmt"

import "time"

import "runtime"

import "sync/atomic"
var runningMultiGoNum int64
func  main() {

	//定时器，防止协程执行超时阻塞进程

	timeOuteRec := 10

	timeout     := 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 action

		ch<- struct{ string }{string: txt}

	}(chn,"Hello World")
   for{

	select {

	case s1:= <-chn:

		fmt.Println(s1.string)

	case <-tk.C:

		fmt.Println("exec over")

		return;

	}

   }

}
 
原创：https://www.panoramacn.com

源码网提供WordPress源码,帝国CMS源码discuz源码,微信小程序,小说源码,杰奇源码,thinkphp源码,ecshop模板源码,微擎模板源码,dede源码,织梦源码等。
专业搭建小说网站,小说程序,杰奇系列,微信小说系列,app系列小说


免责声明,若由于商用引起版权纠纷,一切责任均由使用者承担。
您必须遵守我们的协议，如果您下载了该资源行为将被视为对《免责声明》全部内容的认可->
联系客服
投诉资源
 www.panoramacn.com资源全部来自互联网收集，仅供用于学习和交流，请勿用于商业用途。如有侵权、不妥之处，请联系站长并出示版权证明以便删除。
敬请谅解！ 侵权删帖/违法举报/投稿等事物联系邮箱：2640602276@qq.com
                
                
未经允许不得转载：书荒源码源码网每日更新网站源码模板！ » go并发协程示例
                                
                                    
go并发协程示例
                                
                    

        

            
            
关注我们小说电影免费看
            
关注我们，获取更多的全网素材资源，有趣有料！
            
120000+人已关注
        
    
 
                
                    


                    
分享到：
        
                                赞(0)
        
                    打赏