feizzer 2023-01-06 16:52 采纳率: 63.6%
浏览 13
已结题

go 协程处理。 终止一个可能在运行的协程

问题遇到的现象和发生背景

希望通过golang实现 这样的一直情况, 后台收到请求,开启一个goroutine进行复杂任务处理, 时间十分钟。
如果这十分钟内再次收到请求, 终止之前的goroutine, 重新开始一个任务处理。 怎么处理比较好

主要是想终止一个可能在执行的goroutine

  • 写回答

1条回答 默认 最新

  • ShowMeAI 2023-01-06 17:02
    关注

    如果希望在收到新的请求时终止正在运行的 goroutine,可以使用带缓冲的通道来实现。

    具体来说,可以在主 goroutine 中创建一个带缓冲的通道,并在新的 goroutine 中监听这个通道。当主 goroutine 收到新的请求时,就向通道中发送一个信号,告诉监听的 goroutine 终止运行。

    下面是一个简单的示例代码实现:

    package main
    
    import (
        "fmt"
        "time"
    )
    
    func main() {
        // 创建带缓冲的通道,用于发送信号
        signal := make(chan struct{}, 1)
    
        // 在新的 goroutine 中运行任务
        go func() {
            for {
                // 监听通道,如果收到信号就终止运行
                select {
                case <-signal:
                    return
                default:
                }
    
                // 运行复杂任务,模拟耗时 10 秒
                fmt.Println("开始运行任务")
                time.Sleep(10 * time.Second)
                fmt.Println("任务运行完成")
            }
        }()
    
        // 模拟每隔 5 秒收到一次请求
        for {
            time.Sleep(5 * time.Second)
            fmt.Println("收到新的请求,终止之前的任务")
    
            signal <- struct{}{}
        }
    }
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

问题事件

  • 系统已结题 1月17日
  • 已采纳回答 1月9日
  • 创建了问题 1月6日

悬赏问题

  • ¥20 完全没有学习过GAN,看了CSDN的一篇文章,里面有代码但是完全不知道如何操作
  • ¥15 使用ue5插件narrative时如何切换关卡也保存叙事任务记录
  • ¥20 软件测试决策法疑问求解答
  • ¥15 win11 23H2删除推荐的项目,支持注册表等
  • ¥15 matlab 用yalmip搭建模型,cplex求解,线性化处理的方法
  • ¥15 qt6.6.3 基于百度云的语音识别 不会改
  • ¥15 关于#目标检测#的问题:大概就是类似后台自动检测某下架商品的库存,在他监测到该商品上架并且可以购买的瞬间点击立即购买下单
  • ¥15 神经网络怎么把隐含层变量融合到损失函数中?
  • ¥15 lingo18勾选global solver求解使用的算法
  • ¥15 全部备份安卓app数据包括密码,可以复制到另一手机上运行