go goroutine的理解

1589 0 11个月前 sgfoot 原创

# golang 多线程的概念
> GO语言是从语言层面上支持并发,多线程也是GO语言的强项,也是最迷人的地方

#### 协程Coroutine
>	轻量级 "线程"
	非抢占式多任务处理,由协程主动交出控制权
	编译器/解释器/虚拟机层面的多任务
	多个协程可能在一个或多个线程上运行(是线程的一个子集)由调度器来分配

#### goroutine 的定义
>任何函数只需加上go就能送给调度器运行
	不需要在定义函数时区分是否是异步函数
	调度器在合适的点进行切换
	使用--race 进行调试

#### goroutine 可能的切换点
>	i/o, select
	channel
	等待锁
	函数调用(有时)
	runtime.Gosched()
	不一定会,可能会
	
#  GO语言的goroutine, 信道和死锁

#### goroutine 
> 使用时只需在函数上加一个go关键字,就表示启动了一个goroutine

以下我们使用一个调用普通函数

```
func goroutine() {
	//一个普通的函数
	for i := 0;i < 10; i ++ {
		fmt.Printf("%d ", i)
	}
}

func main() {
	goroutine()
}
```
输出结果:

```
0 1 2 3 4 5 6 7 8 9
```

如果我们在goroutine函数前加一个go的话,什么也没有输出?
> 这是为什么呢?什么也没输出,因为main函数也是一个线程,有自己的生命周期,加了go的函数,只是启动了一个协程,还没来得急执行go 的函数,main已经结束了,当然会杀死go goroutine函数,什么也没有输出,如何让他输出东西呢?在main函数结束上延时一定的时间,让goroutine执行

```
func main() {
	go goroutine()
}
```
改造后的函数

```
func main() {
	go goroutine()
	time.Sleep(time.Millisecond)
}
```

#### 信道
> 分两种,无缓冲信道,缓冲信道
无缓冲信道,存几个消息,必须取走几个消息,否则会阻塞,会报deadlock
缓冲信道,超出缓冲大小,未即时取走的消息也会阻塞,会报deadlock

无缓冲信道
> 无缓冲信道,消息必须即时取走

```
func main() {
	//新建一个无缓冲的信道
	c := make(chan int)
	//开一个协程,不断的取数据
	go func() {
		for{
			fmt.Println(<-c)
		}
	}()
	//向信道发数据
	c <- 1
	c <- 2
	time.Sleep(time.Millisecond)
}
```

缓冲信道
> 超出缓冲大小,需要即时取走

```
func main() {
	//新建一个无缓冲的信道
	c := make(chan int, 2)
	//向信道发数据
	c <- 1
	c <- 2
	time.Sleep(time.Millisecond)
}
```

如果觉得文章对您有用，请给予本站支持！
---sgfoot原创文章,未经许可，禁止转载!

#go #go高级

你可能感兴趣的文章

{{item.title}}