如何使用 Go 语言中的管道创建并行任务？-Golang-PHP中文网

如何使用 Go 语言中的管道创建并行任务？

PHPz

发布： 2024-05-16 21:45:01

原创

402人浏览过

管道是一种无缓冲通信机制，可用于创建并行任务：创建管道：ch := make(chan int)发送数据：ch

如何使用 Go 语言中的管道创建并行任务？

如何使用 Go 语言中的管道创建并行任务

管道是一种无缓冲的通信机制，用于在 Go 协程之间传递数据。管道可以用来创建并行任务，以便同时处理多个输入或输出。

创建管道

使用 make 函数创建管道，并指定要发送或接收的值的类型：

var ch chan int
ch = make(chan int)

登录后复制

发送数据

使用 运算符向管道发送数据：

go func() {
    for i := 1; i <= 5; i++ {
        ch <- i
    }
}()

登录后复制

接收数据

使用 运算符从管道接收数据：

云模块网站管理系统3.1.03

云模块_YunMOK网站管理系统采用PHP+MYSQL为编程语言，搭载自主研发的模块化引擎驱动技术，实现可视化拖拽无技术创建并管理网站！如你所想，无限可能，支持创建任何网站：企业、商城、O2O、门户、论坛、人才等一块儿搞定！永久免费授权，包括商业用途；默认内置三套免费模板。PC网站+手机网站+适配微信+文章管理+产品管理+SEO优化+组件扩展+NEW Login界面.....目测已经遥遥领先..

查看详情

for v := range ch {
    fmt.Println(v)
}

登录后复制

实战案例：求和

下面的示例演示如何使用管道创建并行任务来计算一堆数字的总和：

package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)

    go func() {
        sum := 0
        for i := 1; i <= 1000000; i++ {
            sum += i
        }
        ch <- sum
    }()

    result := <-ch

    fmt.Println("The sum is:", result)
}

登录后复制

在这个示例中，一个协程负责计算总和，并将其发送到管道中。主协程从管道中接收结果并打印出来。

这只是使用管道创建并行任务的一个简单示例。它可以在各种场景中使用，例如：