Golang 并发concurrency

并发concurrency

很多人都是冲着Go大肆宣扬的高并发而忍不住跃跃欲试，但其实从源码解析来看，goroutine只是由官方实现的超级“线程池”而已。不过话说回来，每个实例4-5KB的栈内存占用和由于实现机制而大幅减少的创建和销毁开销，是制造Go号称的高并发的根本原因。另外goroutine的简单易用，也在语言层面上给予了开发者的巨大的便利。

并发不是并行 Concurrency Is Not Parallelism
并发主要由切换时间片来实现“同时”运行，在并行则是直接利用多核实现多线程的运行，但Go可以设置使用核数，以发挥多核计算机的能力
Goroutine 奉行通过通信来共享内存，而不是共享内存来通信。

Channel

Channel 是 goroutine 沟通的桥梁，大都是阻塞同步的
通过 make 创建，close 关闭
Channel 是引用类型
可以使用 for range 来迭代不断操作 channel
可以设置单向或双向通道
可以设置缓存大小，在未被填满前不会发生阻塞

通过 make 创建，close 关闭

package main

import (

	"fmt"

)

func main() {

	c := make(chan bool) //声明一个channel

	go func() {

		fmt.Println("GOOD---")

		c <- true //存入这个channel

	}()

	<-c //取出这个channel

	//当这个main函数执行的时候，遇到gorouting时会直接执行到<-c，此时这个程序会阻塞，一直等到有true存入这个channel(c<-true)，此时(<-c)才能读出来，main函数完成

}

可以使用 for range 来迭代不断操作 channel

package main

import (

	"fmt"

)

func main() {

	c := make(chan bool)

	go func() {

		fmt.Println("GOOD---")

		c <- true

		close(c) //关闭这个channel，迭代操作会终止

	}()

	for v := range c {

		fmt.Println(v)

	}

}

可以设置缓存大小，在未被填满前是异步的，不会发生阻塞

package main

import (

	"fmt"

	"runtime"

)

func main() {

	runtime.GOMAXPROCS(runtime.NumCPU()) //1.8默认使用多核CPU

	c := make(chan bool, 10)

	for i := 0; i < 10; i++ {

		go Go(c, i)

	}

	for i := 0; i < 10; i++ {

		<-c

	}

}

func Go(c chan bool, index int) {

	a := 1

	for i := 0; i < 1000000; i++ {

		a += i

	}

	fmt.Println(index, a)

	c <- true

}

/*

如果设置了缓存大小，大小在未被填满之前，它是异步的，不会发生阻塞

如果这个channel没有缓存的话，要注意取出的操作要在写入的操作的前面

*/

package main

import (

	"fmt"

	"runtime"

	"sync"

)

func main() {

	runtime.GOMAXPROCS(runtime.NumCPU()) //1.8默认使用多核CPU

	wg := sync.WaitGroup{}

	wg.Add(10)

	for i := 0; i < 10; i++ {

		go Go(&wg, i)

	}

	wg.Wait() //通过同步包来实现多个gorouting同步内容

}

func Go(wg *sync.WaitGroup, index int) {

	a := 1

	for i := 0; i < 1000000; i++ {

		a += i

	}

	fmt.Println(index, a)

	wg.Done()

}

/*

如果设置了缓存大小，大小在未被填满之前，它是异步的，不会发生阻塞

如果这个channel没有缓存的话，要注意取出的操作要在写入的操作的前面

*/

Select

可处理一个或多个 channel 的发送与接收
同时有多个可用的 channel时按随机顺序处理
可用空的 select 来阻塞 main 函数
可设置超时

package main

import (

	"fmt"

)

func main() {

	c1, c2 := make(chan int), make(chan string)

	o := make(chan bool)

	go func() {

		for {

			select {

			case v, ok := <-c1:

				if !ok {

					o <- true

					break

				}

				fmt.Println("c1", v)

			case v, ok := <-c2:

				if !ok {

					o <- true

					break

				}

				fmt.Println("c2", v)

			}

		}

	}()

	c1 <- 1

	c2 <- "hi"

	c1 <- 3

	c2 <- "hello"

	close(c1)

	close(c2)

	<-o

}

select设置超时

package main

import (

	"fmt"

	"time"

)

func main() {

	c := make(chan bool)

	select {

	case v := <-c:

		fmt.Println(v)

	case <-time.After(3 * time.Second): //返回的是一个time类型的chan

		fmt.Println("TimeOut")

	}

}

巴特西

Golang 并发concurrency

并发concurrency

Channel

Select

最新文章

热门文章