goroutine 主动终止 golang

2024-10-08 23:40:32 编程来源：ZONE.CI 全球网 0 阅读模式

在golang的并发编程中，goroutine是一种非常重要的概念。它可以让我们以一种简洁、高效的方式实现并发。然而，在实际的开发过程中，我们有时候需要主动终止一个goroutine。本文将介绍如何在golang中主动终止goroutine，并探讨相关的最佳实践。

通过共享变量终止goroutine

在golang中，可以通过共享变量来终止一个goroutine。具体的做法是，在goroutine内部使用一个bool类型的共享变量作为退出标志。在goroutine的循环体中，判断这个标志，当标志为true时，退出循环，从而终止goroutine。

下面是一个示例代码：


func worker(done chan bool) {
    for {
        select {
        case <-done: return="" default:="" do="" some="" work="" }="" }="" }="" func="" main()="" {="" done="" :="make(chan" bool)="" go="" worker(done)="" 等待一段时间后，终止goroutine="" time.sleep(1="" *="" time.second)="" done="" <-="" true="" 继续执行其他逻辑="" }="">

在上面的代码中，我们定义了一个worker函数作为一个goroutine运行的任务。该函数接收一个bool类型的通道done作为参数，在goroutine的循环体内部，我们使用select语句监听done通道。当收到done通道的值时，我们就退出循环，从而终止goroutine。

通过context终止goroutine

除了使用共享变量来终止goroutine之外，golang还提供了更为灵活和安全的方式，那就是使用context。context是一个可以在goroutine之间传递的上下文对象，可以用来控制goroutine的生命周期。

下面是一个使用context来终止goroutine的示例代码：


func worker(ctx context.Context) {
    for {
        select {
        case <-ctx.done(): return="" default:="" do="" some="" work="" }="" }="" }="" func="" main()="" {="" ctx,="" cancel="" :="context.WithCancel(context.Background())" go="" worker(ctx)="" 等待一段时间后，终止goroutine="" time.sleep(1="" *="" time.second)="" cancel()="" 继续执行其他逻辑="" }="">

在上面的代码中，我们首先使用context.WithCancel函数创建了一个可取消的context，然后调用其cancel方法可以主动取消这个context，并通知所有派生自这个context的goroutine终止。