Go语言 - 并发

2021-07-25 14:01:43 阅读：155 来源： 互联网

标签：func 语言 int var 并发 go Go runtime channel

Go语言使用go关键词实现goroutine并发，可以通过channel传输数据。

go关键词修饰函数实现goroutine并发：

func main_go() {
	// runtime.GOMAXPROCS(最大256)
	fmt.Println(runtime.NumCPU()) // 16
	runtime.GOMAXPROCS(8)         // 8核16线程，默认就是runtime.NumCPU()
	var w sync.WaitGroup          // 跟java的countdown差不多
	w.Add(10)
	for i := 0; i < 10; i++ {
		// w.Add(1)
		// 使用go，相当于new Thread().start() . 栈：2K
		go func(i int) {
			defer w.Done()
			fmt.Printf("goooooo:::%d\n", i)
		}(i)
	}

	fmt.Println("demo2")
	w.Wait()
	// time.Sleep(time.Second)
	// `GMP` m:n 把m个G交给n个操作系统线程执行
}

channel变量实现数据交换：

func main_channel() {
	// channel FIFO
	// var a []int
	// var b chan int
	var w sync.WaitGroup
	w.Add(1)

	var c = make(chan int /*, 1*/) // 初始化通道，通道必须初始化才能使用
	go func() {
		x := <-c
		// <- c // 可以直接忽略
		fmt.Printf("x=%d\n", x)
		w.Done()
	}()
	c <- 10
	fmt.Println(c)
	// 关闭通道
	close(c)
	w.Wait()
	// <- 不管是发送还是接受，都使用这个符号
	// 发送：c <- 1
	// 接受：x := <- c
	// 关闭close()

	// 单向通道
	var get_channel <-chan int // 只能取
	var put_channel chan<- int // 只能存
	get_channel = make(<-chan int)
	put_channel = make(chan<- int)
	fmt.Println(get_channel, put_channel)
}

标签：func,语言,int,var,并发,go,Go,runtime,channel
来源： https://www.cnblogs.com/itqn/p/15057684.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

Go语言 - 并发