- 前言
- Go 与操作系统
- Go 内部机制
- Go 基本数据类型
- 4 组合类型的使用
- 5 数据结构
- 6 Go package 中不为人知的知识
- 7 反射和接口
- 8 Go UNIX 系统编程
- 08.1 关于 UNIX 进程
- 08.2 flag 包
- 8.2 flag 包
- 08.3 io.Reader 和 io.Writer 接口
- 08.4 bufio 包
- 08.5 读取文本文件
- 08.6 从文件中读取所需的数据量
- 08.7 为什么我们使用二进制格式
- 08.8 读取 CSV 文件
- 08.9 写入文件
- 08.10 从磁盘加载和保存数据
- 08.11 再看strings包
- 08.12 关于bytes包
- 08.13 文件权限
- 08.14 处理 Unix 信号
- 08.15 Unix 管道编程
- 08.16 遍历目录树
- 08.17 使用 ePBF
- 08.18 关于 syscall.PtraceRegs
- 08.19 跟踪系统调用
- 08.20 User ID 和 group ID
- 08.21 其他资源
- 08.22 练习
- 08.23 总结
- 9 并发 Goroutines、Channel 和 Pipeline
- 10 Go 并发-进阶讨论
- 11 代码测试、优化及分析
- 12 Go 网络编程基础
- 13 网络编程 - 构建服务器与客户端
10.3.1 方式1
第一个技巧的源码保存在 timeOut1.go
中,并分为四部分介绍。
timeOut1.go
的第一部分显示如下代码:
package main
import (
"fmt"
"time"
)
timeOut1.go
第二段代码如下:
func main() {
c1 := make(chan string)
go func () {
time.Sleep(time.Second * 3)
c <- "c1 OK"
}()
time.Sleep()
调用用于模拟函数完成其工作通常需要的时间。在这个例子里,匿名函数以 goroutine 方式执行,它将在大约 3 秒(time.Second * 3
)后写消息到 c1
channel。
timeOut1.go
的第三段包含如下代码:
select {
case res := <- c1:
fmt.Println(res)
case <- time.After(time.Second * 1):
fmt.Println("timeout c1")
}
time.After()
函数调用的目地是等待指定时间。这个例子中,您不用关心 time.After()
返回的实际值,但实际上 time.After()
函数调用介绍意味着超时了。例子中由于 time.After()
函数指定的值小于上节以 goroutine 方式执行的 time.Sleep()
调用中使用的值,您极有可能得到一个超时信息。
timeOut1.go
的其余代码如下:
c2 := make(chan string)
go func() {
time.Sleep(3 * time.Second)
c2 <- "c2 OK"
}()
select {
case res := <-c2:
fmt.Println(res)
case <- time.After(4 * time.Second):
fmt.Println("timeout c2")
}
}
上面这段代码执行一个 goroutine 并使用 time.After(4 * time.Second)
定义了一个 4 秒的超时期限,由于 time.Sleep()
的调用,这个goroutine 将执行大约 3 秒。如果 time.After(4 * time.Second)
调用的返回在您从 select
块的第一个分支里的 c2 channel 获得值之后,那么就不会超时;否则,将超时!然而,在这个例子中,time.After()
调用的值提供了足够的时间对于 time.Sleep()
调用的返回,因此您极可能不会得到一个超时信息。
执行 timeOut1.go
产生如下输出:
$go run timeOut1.go
timeout c1
c2 OK
正如期望的,第一个 goroutine 没有完成它的工作,而第二个有足够的时间去完成。
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论