如何终止一个正在进行的协程? - V2EX
The Go Programming Language
http://golang.org/
Go Playground
Go Projects
Revel Web Framework
777777

如何终止一个正在进行的协程?

  •  
  •   777777 Aug 30, 2021 4398 views
    This topic created in 1715 days ago, the information mentioned may be changed or developed.

    利用 context.WithCancel()来终止协程,但存在一个问题:cancel()执行后,必须等 for 循环执行完毕 goroutine 才退出。

    for { select { case <-Ctx.Done(): return default: fr i := 0; i < 100; i++ { // 业务逻辑 } } } 

    需求为:cancel()后协程立马退出不再执行后面的循环。
    目前我的解决方法:单独起一个协程用来监听退出信号,然后通过全局变量通知业务逻辑循环退出。

    flag := false go func() { for { select { case <-Ctx.Done(): flag = true return } }() for i:=0; i < 100; i++ { if flag { return } // 业务逻辑 } 

    请问最佳实践应该是如何退出?

    Supplement 1    Aug 30, 2021
    是这样一个场景:用户创建任务,起一个 goroutine 去执行,执行过程中,用户想要取消这个任务。
    Supplement 2    Aug 30, 2021
    for i := 0; i < 100; i++ { select { case <-Ctx.Done(): return default: // 业务逻辑 } } 

    感谢大家的回答,每次循环都检测一次退出信号就好了。
    延伸出另一个问题:用户取消任务,如何让default里的业务逻辑立马终止?

    Supplement 3    Aug 30, 2021

    看了一下os.exec.cmd.Start()的源码

     if c.ctx != nil { c.waitDOne= make(chan struct{}) go func() { select { case <-c.ctx.Done(): c.Process.Kill() case <-c.waitDone: } }() } 

    另起一个goroutine监听cancel(),然后kill掉执行的process。
    类比本问题,一个协程执行任务,一个协程监听任务的cancel(),任务取消直接kill掉执行任务的协程且监听协程也退出。

    21 replies    2021-09-01 18:30:13 +08:00
    dream10201
        1
    dream10201  
       Aug 30, 2021
    瞎想的,你把 select case 放到 for 循环里面不行?
    dream10201
        2
    dream10201  
       Aug 30, 2021
    for {
    for i := 0; i < 100; i++ {
    select {
    case <-Ctx.Done():
    return
    default:
    // 业务逻辑
    }
    }
    }
    14v45mJPBYJW8dT7
        3
    14v45mJPBYJW8dT7  
       Aug 30, 2021
    ```
    for {
    for i := 0; i < 100; i++ {
    select {
    case <-Ctx.Done():
    return
    default:
    // 业务逻辑
    }
    }
    }```
    BBCCBB
        4
    BBCCBB  
       Aug 30, 2021
    这种可以在 for 里每次检测 ctx.Done()... 不过不是最佳实践.
    和你图中这个方法差不多,, 不过不知道你图中这个方法有没有变量可见性的问题? 导致 flag=true 后在当前协程并不可见?
    777777
        5
    777777  
    OP
       Aug 30, 2021
    @BBCCBB 是可见的
    777777
        6
    777777  
    OP
       Aug 30, 2021
    @dream10201 这样有问题吧,如果不调用 cancel(),最外面 for 循环不会退出。
    sadfQED2
        7
    sadfQED2  
       Aug 30, 2021 via Android
    这个问题我在 java 里面也研究过,最后结果就是无解,只能业务代码里面每次循环都判断
    xx6412223
        8
    xx6412223  
       Aug 30, 2021
    直接退出就不是合理的设计。
    caryqy
        9
    caryqy  
       Aug 30, 2021
    执行前检查 Done,

    执行后提交前再次检查 Done,根据结果来收尾。

    考虑的粒度即使再细都会碰到 执行中取消 这个问题,所以到某个程度之后就 禁止用户取消
    haochen2
        10
    haochen2  
       Aug 30, 2021
    如果业务逻辑超时运行或着阻塞,根本走不到 ctx.Done 那个 case 的地方
    cpstar
        11
    cpstar  
       Aug 30, 2021
    循环第二位置用 i<100&&ctx.done() 不好么?还非得一个 switch-case ?
    至于楼上说的业务阻塞,那就得放到业务里边继续判断了。

    多线程运转,直接干掉线程,哈
    MidGap
        12
    MidGap  
       Aug 30, 2021
    runtime.Goexit()
    fpure
        13
    fpure  
       Aug 30, 2021
    @sadfQED2 Java 里面哪有什么协程?
    sadfQED2
        14
    sadfQED2  
       Aug 30, 2021 via Android
    @fpure java 线程
    s4nd
        15
    s4nd  
       Aug 30, 2021
    老哥,你这头像是认真的吗,nft 大佬
    MineDog
        16
    MineDog  
       Aug 30, 2021
    @sadfQED2 #7 java 怎么会无解呢,java 一般就是 Interrupted+状态判断啊
    cheng6563
        17
    cheng6563  
       Aug 31, 2021
    @sadfQED2 Java 一顿 Interrupt 就行了,只不过没人管 InterruptedException 倒是真的
    codeface
        18
    codeface  
       Aug 31, 2021
    caoyouming
        19
    caoyouming  
       Sep 1, 2021
    你这里的 c 表示的是什么呀?
    ltf127001
        20
    ltf127001  
       Sep 1, 2021
    @caoyouming 根据我在菜鸟教程学了两天 go 的经验,这个应该是个通道( channel )
    caoyouming
        21
    caoyouming  
       Sep 1, 2021
    @ltf127001 #20 if c.ctx != nil {
    c.waitDOne= make(chan struct{})
    go func() {
    select {
    case <-c.ctx.Done():
    c.Process.Kill()
    case <-c.waitDone:
    }
    }()
    }

    这里的 c 应该不是 channel 吧?
    About     Help     Advertise     Blog     API     FAQ     Solana     1025 Online   Highest 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 95ms UTC 22:27 PVG 06:27 LAX 15:27 JFK 18:27
    Do have faith in what you're doing.
    ubao msn snddm index pchome yahoo rakuten mypaper meadowduck bidyahoo youbao zxmzxm asda bnvcg cvbfg dfscv mmhjk xxddc yybgb zznbn ccubao uaitu acv GXCV ET GDG YH FG BCVB FJFH CBRE CBC GDG ET54 WRWR RWER WREW WRWER RWER SDG EW SF DSFSF fbbs ubao fhd dfg ewr dg df ewwr ewwr et ruyut utut dfg fgd gdfgt etg dfgt dfgd ert4 gd fgg wr 235 wer3 we vsdf sdf gdf ert xcv sdf rwer hfd dfg cvb rwf afb dfh jgh bmn lgh rty gfds cxv xcv xcs vdas fdf fgd cv sdf tert sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf shasha9178 shasha9178 shasha9178 shasha9178 shasha9178 liflif2 liflif2 liflif2 liflif2 liflif2 liblib3 liblib3 liblib3 liblib3 liblib3 zhazha444 zhazha444 zhazha444 zhazha444 zhazha444 dende5 dende denden denden2 denden21 fenfen9 fenf619 fen619 fenfe9 fe619 sdf sdf sdf sdf sdf zhazh90 zhazh0 zhaa50 zha90 zh590 zho zhoz zhozh zhozho zhozho2 lislis lls95 lili95 lils5 liss9 sdf0ty987 sdft876 sdft9876 sdf09876 sd0t9876 sdf0ty98 sdf0976 sdf0ty986 sdf0ty96 sdf0t76 sdf0876 df0ty98 sf0t876 sd0ty76 sdy76 sdf76 sdf0t76 sdf0ty9 sdf0ty98 sdf0ty987 sdf0ty98 sdf6676 sdf876 sd876 sd876 sdf6 sdf6 sdf9876 sdf0t sdf06 sdf0ty9776 sdf0ty9776 sdf0ty76 sdf8876 sdf0t sd6 sdf06 s688876 sd688 sdf86