golang并发模式揭秘-Golang-PHP中文网

golang并发模式揭秘

WBOY

发布： 2024-07-03 23:36:01

原创

398人浏览过

golang 的并发模式利用以下原语：goroutine（轻量级并发执行单元）、channel（通信通道）、sync.mutex（互斥锁）。实战案例使用这些原语并行执行任务，并使用无缓冲 channel 存储任务结果，使用 sync.mutex 保护对结果的并发访问，最终收集并打印结果。

golang并发模式揭秘

Golang 并发模式揭秘

Golang 是一个高并发、高性能的编程语言，其内置的并发原语提供了强大的并发功能。本文将深入探讨 Golang 的并发模式，并通过实战案例演示如何有效地管理并发。

并发模式

goroutine 是 Golang 的轻量级并发执行单元，可以并发执行不同的任务。go 关键字用于创建新的 goroutine。

channel 是通信通道，用于在 goroutine 之间传递数据。channel 通常是无缓冲或有缓冲的。

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

sync.Mutex 用于互斥锁，防止并发访问共享数据。

实战案例

下面是一个使用 goroutine 和 channel 并发执行多个任务的示例：

package main

import (
    "fmt"
    "sync"
    "time"
)

func main() {
    // 创建一个无缓冲 channel，用于存储任务结果
    resultChan := make(chan int)

    // 创建一个 mutex，用于控制对结果的访问
    var mu sync.Mutex

    // 创建并启动 10 个 goroutine 并发执行任务
    for i := 0; i < 10; i++ {
        go func(i int) {
            result := i * i
            fmt.Printf("Goroutine %d completed with result %d\n", i, result)

            mu.Lock()
            resultChan <- result
            mu.Unlock()
        }(i)
    }

    // 等待所有 goroutine 完成任务并收集结果
    results := make([]int, 10)
    for i := 0; i < 10; i++ {
        results[i] = <-resultChan
    }

    // 打印最终结果
    fmt.Println("Final results:", results)

    time.Sleep(time.Second) // 等待 goroutine 退出
}

登录后复制

在这个示例中：