golang chan 超时

golang chan 超时

Posted on 2013-12-24 13:03 oathleo 阅读(4227) 评论(0)  编辑  收藏

package main

import (
    "fmt"
    "time"
)

var ch chan int = make(chan int, 1)

func main() {
    go aaa()

select {
    case <-ch: //拿到锁
        fmt.Println("call")
    case <-time.After(5 * time.Second): //超时5s
        fmt.Println("5 sec call")
    }
}

func aaa() {
    time.Sleep(time.Second * 3)
    ch <- 1
}

时间: 2024-11-13 11:27:12

golang chan 超时的相关文章

Golang: chan定义问题(7)

通常都是定义读写双向的 chan,定义单向 chan 问题. 专栏的介绍可以参考 <GotchaGolang专栏>,代码可以看<宝库-Gotcha>. 通过 只写 chan 传递另一个只读的 chan,怎么写? 案例 平常一般是这么声明 chan 的: 12345678910 package main import "fmt" func () { xChan := make(chan int) fmt.Println(len(xChan)); //0} 要声明一

golang网络通信超时设置

网络通信中,为了防止长时间无响应的情况,经常会用到网络连接超时.读写超时的设置. 本文结合例子简介golang的连接超时和读写超时设置. 1.超时设置 1.1 连接超时 func DialTimeout(network, address string, timeout time.Duration) (Conn, error) 第三个参数timeout可以用来设置连接超时设置. 如果超过timeout的指定的时间,连接没有完成,会返回超时错误. 1.2 读写超时 在Conn定义中,包括读写的超时时

golang chan 发送接收测试数据

测试代码: package main import (     "fmt"     "time" ) const (     num = 10000000  // 测试1千万次发送和接收 ) func main() {     TestChan2() } func TestChan2() {     st := time.Now().UnixNano()     c := make(chan int)     go func() {         var n in

Golang os/exec 实现

os/exec 实现了golang调用shell或者其他OS中已存在的命令的方法. 本文主要是阅读内部实现后的一些总结. 如果要运行ls -rlt,代码如下: package main import ( "fmt" "log" "os/exec" ) func main() { cmd := exec.Command("ls", "-rlt") stdoutStderr, err := cmd.Combin

Golang编程经验总结

如何选择web框架: 首先Golang语言开发web项目不一定非要框架,本身已经提供了Web开发需要的一切必要技术.当然如果想要ruby里面Rail那种高层次全栈式的MVC框架, Golang里面暂时没有,但是不是所有人都喜欢这种复杂的框架.Golang里面一些应用层面的技术需要自己去组装,比如session,cache, log等等. 可选择的web框架有martini, goji等,都是轻量级的. Golang的web项目中的keepalive 关于keepalive, 是比较复杂的, 注意

golang学习的点点滴滴:并发超时处理

golang并没有在语言层次上提供超时操作,但可以通过一些小技巧实现超时. 原理: 并发一个函数,等待1s后向timeout写入数据,在select中如果1s之内有数据向其他channel写入则会顺利执行,如果没有,这是timeout写入了数据,则我们知道超时了. package main  import "fmt" import "time" func main() { ch := make(chan int, 1) timeout := make(chan bo

golang中channel的超时处理

并发中超时处理是必不可少的,golang没有提供直接的超时处理机制,但可以利用select机制来解决超时问题. func timeoutFunc() { //首先,实现并执行一个匿名的超时等待函数 timeout := make(chan bool, 1) go func() { time.Sleep(1e9) //等待1秒钟 timeout <- true }() //然后,我们把timeout这个channel利用起来 select { case <- ch: //从ch中读到数据 cas

golang net http库相关超时的设置

net.http 包中的超时设置 app.Server.ReadTimeout app.Server.WriteTimeout 是针对所有请求设置的选项 默认 net.http keepalived 开启,超时时间为 3 分钟,如下 1942    type tcpKeepAliveListener struct { 1943          *net.TCPListener 1944    } 1945 1946    func (ln tcpKeepAliveListener) Accep

golang中mysql建立连接超时时间timeout 测试

本文测试连接mysql的超时时间. 这里的"连接"是建立连接的意思. 连接mysql的超时时间是通过参数timeout设置的. 1.建立连接超时测试 下面例子中,设置连接超时时间为5s,读超时时间6s. MySQL server IP是192.168.0.101,端口3306. 每3s执行一次SQL. // simple.go package main import ( "database/sql" "log" "time"