golang如何在超时的时候停止子程序的执行,主程序不停止的情况下

zichen · 2018-10-12 20:02:39 · 1643 次点击 · 大约8小时之前 开始浏览    置顶
这是一个创建于 2018-10-12 20:02:39 的主题,其中的信息可能已经有所发展或是发生改变。

package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan string)
    go doit(ch)
    for {
        select {
        case msg := <-ch:
            fmt.Println(msg)
            return
        case <-time.After(3 * time.Second):
            fmt.Println("本次执行超过3秒,已停止")
            //需要这里停止之后,不再打印【超时之后的内容】这句话
            time.Sleep(5 * time.Second)
            return
        }
    }
}
func doit(ch chan string) {
    msg := ""
    fmt.Println("开始执行")
    time.Sleep(5 * time.Second)
    fmt.Println("超时之后的内容")
    ch <- msg
}

我期望得到的是

开始执行
本次执行超过3秒,已停止

现在得到的是

开始执行
本次执行超过3秒,已停止
超时之后的内容

有疑问加站长微信联系(非本文作者)

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1643 次点击  
加入收藏 微博
3 回复  |  直到 2018-10-18 10:59:28
mlzhou
mlzhou · #1 · 7年之前

协程之间同步咯,另外加一个带缓冲的chan,主线程执行完后,往里面塞东西,子协程time.sleep后看该chan是否有值,有就跳过,说明主线程执行完毕

func main() {
    ch := make(chan string)
    bfch := make(chan uint8, 1)
    go doit(ch, bfch)
    for {
        select {
        case msg := <-ch:
            fmt.Println(msg)
            return
        case <-time.After(3 * time.Second):
            fmt.Println("本次执行超过3秒,已停止")
            //需要这里停止之后,不再打印【超时之后的内容】这句话
            bfch <- 1
            time.Sleep(5 * time.Second)
            return
        }
    }
}

func doit(ch chan string, bfch chan uint8) {
    msg := ""
    fmt.Println("开始执行")
    time.Sleep(5 * time.Second)
    if len(bfch) == 0 {
        fmt.Println("超时之后的内容")
    }

    ch <- msg
}
jingyugao
jingyugao · #2 · 7年之前

context

snryang
snryang · #3 · 7年之前

主程序不停止,协助将会一直执行,要想协助中的某部分代码不执行,只能给协助传递一个信号(通过chanel或者变量等),协助内部做判断。 另外代码中的for{} return 是多余的吧,select case会自动阻塞吧。

添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传