golang怎么中断协程-Golang-PHP中文网

在 Go 中有三种中断协程的方法：通过通道通信、使用原子值标记中断需求、或者引发 panic 并恢复。

golang怎么中断协程

如何在 Go 中中断协程

协程是 Go 语言中的一种并发原语，它允许程序并行执行多个任务。然而，有时需要中断正在运行的协程。可以通过以下方式中断协程：

使用通道

通道是一种用于在协程之间通信的并发机制。要中断协程，可以使用一个只会关闭一次的通道。当协程接收到关闭的通道时，它将停止执行。

立即学习“go语言免费学习笔记（深入）”；

BizPower CRM客户管理系统

通过使用BizPower CRM解决方案，您的员工、生产过程及信息能够与客户保持着平稳、无间断的联络，并且能够通过以客户为焦点、创新的产品和服务；以客户为中心，更高层次的生产过程；持久有益的客户关系这三个方面创造有价值客户的领导关系。选择Bizpower CRM的原因1、灵活的数据权限和功能权限BizPower CRM 系统通过引入了灵活的数据权限和功能权限，模仿现实中协同工作的实际情况。实现企

下载

import (
    "sync"
)

func main() {
    // 创建一个等待中断的协程
    wg := &sync.WaitGroup{}
    wg.Add(1)
    go func() {
        defer wg.Done()
        for {
            select {
            case <-interruptChannel:
                return
            }
        }
    }()

    // 稍后向通道发送信号以中断协程
    interruptChannel <- struct{}{}

    // 等待协程完成
    wg.Wait()
}

使用原子值

原子值是一种可以在并发环境中安全读取和写入的值。要中断协程，可以使用原子值来标记协程需要中断。

import (
    "sync/atomic"
)

func main() {
    // 创建一个等待中断的协程
    var interrupted int32
    go func() {
        for atomic.LoadInt32(&interrupted) == 0 {
            // 协程持续运行
        }
    }()

    // 稍后设置原子值为非零以中断协程
    atomic.StoreInt32(&interrupted, 1)
}

使用 panic 恢复

panic 恢复是一种在 Go 中处理错误的机制。要中断协程，可以引发 panic 并让另一个协程恢复它。

func main() {
    // 创建一个等待中断的协程
    go func() {
        defer recover()
        // 协程持续运行
    }()

    // 稍后引发 panic 以中断协程
    panic("协程被中断")
}