Comment fermer et annuler les opérations de pipeline à l'aide d'un pipeline en langage Go ?

Dans Go, la fermeture du pipeline enverra une valeur implicite nulle, indiquant que l'envoi ultérieur échoue ; lors de l'annulation de l'opération du pipeline, utilisez context.WithCancel() pour créer un contexte avec la fonction d'annulation et appelez la fonction Cancel() pour annuler le opération, ce qui entraîne l’arrêt de l’exploitation du pipeline.

Fermeture et annulation des opérations de pipeline en langage Go

Les pipelines sont un outil important pour la programmation simultanée en langage Go. Il est essentiel de comprendre et d'utiliser correctement les fonctions de fermeture et d'annulation du canal.

Fermeture du tuyau

Après avoir envoyé toutes les données nécessaires au tuyau, vous pouvez appeler la fonction close(ch) pour fermer le tuyau. Cela enverra une valeur implicite nil au canal, indiquant que les envois suivants échoueront. close(ch) 函数关闭管道。这会向管道发送一个隐式值 nil，表示后续发送都会失败。

package main

import "fmt"

func main() {
  ch := make(chan int)
  
  go func() {
    // 发送一些值
    ch <- 1
    ch <- 2
    
    // 关闭管道
    close(ch)
  }()
  
  // 接收管道中的值
  for v := range ch {
    fmt.Println(v)
  }
  
  // Pipline 已经关闭，接收操作将会退出并打印 "<nil>"
  fmt.Println(<-ch)
}

取消管道操作

在某些情况下，可能需要取消管道操作，而无需等待所有数据都被发送和接收。可以使用 context.WithCancel() 函数创建带有取消功能的上下文。

package main

import (
  "context"
  "fmt"
)

func main() {
  ctx, cancel := context.WithCancel(context.Background())
  
  ch := make(chan int)
  
  go func() {
    // 发送一些值
    for i := 0; i < 5; i++ {
      select {
        case <-ctx.Done():
          return
        case ch <- i:
      }
    }
  }()
  
  // 取消管道操作
  cancel()
  
  // 接收管道中的值
  for v := range ch {
    fmt.Println(v)
  }
}

在上面的示例中，调用 cancel()rrreee

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!