[golang]time.After 在select中使用的正确姿势（解决超时逻辑未生效bug）

大佬教程收集整理的这篇文章主要介绍了[golang]time.After 在select中使用的正确姿势（解决超时逻辑未生效bug），大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

前言

SELEct 的语法如下所示

每个case都必须是一个通信
所有chAnnel表达式都会被求值
所有被发送的表达式都会被求值
如果任意某个通信可以进行，它就执行；其他被忽略。
如果有多个case都可以运行，SELEct会随机公平地选出一个执行。其他不会执行。 
否则：如果有default子句，则执行该语句。
如果没有default字句，SELEct将阻塞，直到某个通信可以运行；Go不会重新对chAnnel或值进行求值。

问题复现

package main

import(
    "fmt"
    "time"
)

func add(ch chan int) {
    for i:=0;i<10;i++{
        ch <- i
    }
}

// timeout problem recurrent
func test2() {
    ch := @H_66_51@make(chan int, 10)
    go add(ch)
    for {
        SELEct {
            case <- time.After(2 * time.Second):
                fmt.Println("timeout")
                return
            case <- ch:
                fmt.Println(ch) // if ch not empty,time.After will nerver exec
                fmt.Println("sleep one seconds ...")
                time.Sleep(1 * time.Second)
                fmt.Println("sleep one seconds end...")
        }
    }
}

根据条件5：如果有多个case都可以运行，SELEct会随机公平地选出一个执行。其他不会执行。
但是运行上述代码，当ch通道中存在数据时，time.After总是得不到运行，因此到时超时未生效（就像是两个case都成立时，SELEct 都”公平”地选择了 case <- ch，导致超时逻辑未生效）

改进1

func test3() {
    ticker := time.NewTicker(2 * time.Second)
    defer ticker.Stop()
    ch := @H_66_51@make(chan int, 10)
    go add(ch)
    for {
        SELEct {
            case <- ch:
                fmt.Println(ch) // if ch not empty,time.After will nerver exec
                fmt.Println("sleep one seconds ...")
                time.Sleep(1 * time.Second)
                fmt.Println("sleep one seconds end...")
            case <- ticker.C:
                fmt.Println("timeout")
                return
            default:
        }
    }
}

改进1 随机性失败
当case <- ch 和 case <- ticker.C 同时成立时，SELEct会随机公平地选出一个执行，有可能选择到前者，导致超时随机行失败

最终解决方式

// final solution
func test4() {
    ticker := time.NewTicker(2 * time.Second)
    defer ticker.Stop()
    ch := @H_66_51@make(chan int,time.After will nerver exec
                fmt.Println("sleep one seconds ...")
                time.Sleep(1 * time.Second)
                fmt.Println("sleep one seconds end...")
            default: // forbid block
        }
        SELEct {
            case <- ticker.C:
                fmt.Println("timeout")
                return
            default: // forbid block
        }
    }
}

将【超时】和【收包】放在各自单独的SELEct里面，【超时】一定可以执行到

参考文档

go里面select-case和time.Ticker的使用注意事项
go语言time包用法

大佬总结

以上是大佬教程为你收集整理的[golang]time.After 在select中使用的正确姿势（解决超时逻辑未生效bug）全部内容，希望文章能够帮你解决[golang]time.After 在select中使用的正确姿势（解决超时逻辑未生效bug）所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。