Golang语言-并发支持
Golang 运行时(runtime)管理了一种轻量级线程,被叫做 goroutine。创建数十万级的 goroutine 是没有问题的。范例:
package main
import (
"fmt"
"time"
)
func say(s string) {
for i := 0; i < 5; i++ {
time.Sleep(100 * time.Millisecond)
fmt.Println(s)
}
}
func main() {
// 开启一个 goroutine 执行 say 函数
go say("world")
say("hello")
}
我们使用 channel 和 goroutine 通讯。channel 中是一种带有类型的通道,被用于接收和发送特定类型的值。操作符 <- 被叫做 channel 操作符(这个操作符中箭头表明了值的流向):
// 发送 v 到 channel ch ch <- v // 接收 channel ch 中的值并赋值给 v v := <-ch
使用 channel 和 goroutine 通讯能够避免显式使用锁机制,通过 channel 发送和接收值时默认是阻塞的。
通过 make 函数创建 channel:
// int 指定 channel 收发值的类型为 int ch := make(chan int)
一个完整的例子:
package main
import "fmt"
// 计算数组 a 中所有元素值之和
func sum(a []int, c chan int) {
sum := 0
for _, v := range a {
sum += v
}
// 计算结果发送到 channel c
c <- sum
}
func main() {
a := []int{7, 2, 8, -9, 4, 0}
// 创建 channel c
c := make(chan int)
go sum(a[:len(a)/2], c)
go sum(a[len(a)/2:], c)
// 接收两个 goroutine 发送的计算结果
x, y := <-c, <-c
fmt.Println(x, y, x+y)
}package main
import "fmt"
// 计算数组 a 中所有元素值之和
func sum(a []int, c chan int) {
sum := 0
for _, v := range a {
sum += v
}
// 计算结果发送到 channel c
c <- sum
}
func main() {
a := []int{7, 2, 8, -9, 4, 0}
// 创建 channel c
c := make(chan int)
go sum(a[:len(a)/2], c)
go sum(a[len(a)/2:], c)
// 接收两个 goroutine 发送的计算结果
x, y := <-c, <-c
fmt.Println(x, y, x+y)
}
channel 可以带有一个缓冲区(buffer)来缓存被传递的值,向 channel 中发送时只有缓冲区满的情况下会阻塞,接收 channel 中的值时只有在缓冲区空的情况下阻塞:
复制代码代码如下:
package main import "fmt" func main() { // 创建 channel,缓冲区长度为 2 c := make(chan int, 2) // 由于 channel 的缓冲区长度为 2 // 因此发送不会阻塞 c <- 1 c <- 2 fmt.Println(<-c) fmt.Println(<-c) }
发送者可以调用 close 来关闭 channel,接收者可以检测到 channel 是否被关闭:
// 这里的 ok 为 false 表示已经没有值可以接收了,并且 channel 被关闭了 v, ok := <-ch
不要向已经关闭的 channel 发送值了(will cause a panic)。
我们可以使用 for range 来接收 channel 中的值:
package main
import "fmt"
func fibonacci(n int, c chan int) {
x, y := 0, 1
for i := 0; i < n; i++ {
c <- x
x, y = y, x+y
}
// 必须要关闭 c
close(c)
}
func main() {
c := make(chan int, 10)
go fibonacci(cap(c), c)
// 这里 for 和 range 组合使用
// 不断的接收 c 中的值一直到它被关闭
for i := range c {
fmt.Println(i)
}
}
通常来说,我们不需要主动的关闭 channel。但有时候接收者必须被告知已经没有值可以接收了,这时候主动关闭是必要的,例如终止 for range 循环。
使用 select 语句可以让一个 goroutine 等待多个通讯操作。select 会阻塞直到某个 case 能够运行,如果同时存在多个可执行的,那么将随机选择一个:
package main
import "fmt"
func fibonacci(c, quit chan int) {
x, y := 0, 1
for {
select {
case c <- x:
x, y = y, x+y
// 控制此线程退出
case <-quit:
fmt.Println("quit")
return
}
}
}
func main() {
c := make(chan int)
quit := make(chan int)
go func() {
for i := 0; i < 10; i++ {
fmt.Println(<-c)
}
quit <- 0
}()
fibonacci(c, quit)
}
select 中的 default 会在没有任何 case 可执行时执行(类似于 switch):
复制代码代码如下:
package main
import (
"fmt"
"time"
)
func main() {
// 创建一个 tick channel
// 在 100 毫秒后会向 tick channel 中发送当前时间
tick := time.Tick(100 * time.Millisecond)
// 创建一个 boom channel
// 在 500 毫秒后会向 boom channel 中发送当前时间
boom := time.After(500 * time.Millisecond)
for {
select {
case <-tick:
fmt.Println("tick.")
case <-boom:
fmt.Println("BOOM!")
return
default:
fmt.Println(" .")
time.Sleep(50 * time.Millisecond)
}
}
}
- 关于某道C#上机题的OO
- Android 事件处理探险
- Fluent NHibernate RC 1.0 --升级内容
- 驳“反驳老赵之“伪”递归”
- 关于今天很热的--FizzBuzzWhizz
- 了解EF CodeFirst的Migrator功能与Migrator.Net对比
- struts技术的logic标签
- 【翻译】使用Visual Studio创建Asp.Net Core MVC (一)
- 你不知道的Javascript:有趣的setTimeout
- ADO.NET 2.0 中的新增 DataSet 功能
- WinRar 4.20 – 文件扩展名欺骗(0Day)
- 黑掉ATM取款机?只需一条短信
- DNS迭代穷举脚本
- 走进计算机取证分析的神秘世界
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 彻底搞懂 etcd 系列文章(六):etcd 核心 API v3
- Open3d学习计划—7(RGBD测程法)
- 一次信息泄露引发的越权
- MySQL 调优 | OPTIMIZER_TRACE 详解
- 这次被坑惨了,MySQL的隐式转换导致了一个线上BUG
- iOS开发之UIMenu
- mysql必会技能-基本操作
- 移动端跨平台技术之下的变与不变
- java-JDBC操作Mysql
- 【深度知识】25种区块链共识算法全面详解
- 聊聊 resolv.conf 中 search 和 ndots 配置
- 数据库-实验二
- Rust Stable 1.45 中的 神奇 Bug 解读
- 快速提升Python数据分析能力的七个神奇方法
- 策略模式 - go篇