2010年07月13日 Go生态洞察：通过通信来共享内存

news2024/11/25 6:22:51

🌷🍁 博主猫头虎（🐅🐾）带您 Go to New World✨🍁

🦄 博客首页——🐅🐾猫头虎的博客🎐
🐳 《面试题大全专栏》 🦕 文章图文并茂🦖生动形象🐅简单易学！欢迎大家来踩踩~🌺
🌊 《IDEA开发秘籍专栏》 🐾 学会IDEA常用操作，工作效率翻倍~💐
🌊 《100天精通Golang(基础入门篇）》 🐅 学会Golang语言，畅玩云原生，走遍大小厂~💐

🐅🐾猫头虎建议Go程序员必备技术栈一览表📖：

☁️🐳 Go语言开发者必备技术栈☸️:
🐹 GoLang | 🌿 Git | 🐳 Docker | ☸️ Kubernetes | 🔧 CI/CD | ✅ Testing | 💾 SQL/NoSQL | 📡 gRPC | ☁️ Cloud | 📊 Prometheus | 📚 ELK Stack

🪁🍁 希望本文能够给您带来一定的帮助🌸文章粗浅，敬请批评指正！🐅🐾🍁🐥

在这里插入图片描述

文章目录

- 🐅🐾猫头虎建议Go程序员必备技术栈一览表📖：
2010年07月13日 Go生态洞察：通过通信来共享内存
- 📜 摘要
- 🎤 引言
- 📚 正文内容
- - 1. 传统并发模型的挑战
  - 2. Go的并发哲学
  - 3. Go的实践案例：URL轮询器
  - 4. Go并发的深层洞察
- 🔍 总结
- 📚 参考资料
- 📅 下一篇预告
原创声明

原创作者：猫头虎
作者wx： [ libin9iOak ]
作者公众号： [ 猫头虎技术团队 ]

在这里插入图片描述

2010年07月13日 Go生态洞察：通过通信来共享内存

📜 摘要

喵，猫头虎博主在这里给大家带来Go语言的一大精髓——通过通信来共享内存！在这个充满线程和锁的传统编程世界里，Go用它的goroutines和channels给我们展示了另一种优雅的并发编程风格。今天，我们就来深挖一下这个话题，看看Go是如何通过通信而不是通过共享内存来处理并发的。Go并发模型、goroutines、channels、共享内存。

🎤 引言

在Go的世界里，我们有一条黄金法则：不要通过共享内存来通信；而应该通过通信来共享内存。这条法则看起来可能有点拗口，但它深刻影响了Go程序设计的每一个角落。今天，我们就来探讨这背后的哲学，并对比传统的线程模型，深入理解Go如何改变了并发编程的游戏规则。

📚 正文内容

1. 传统并发模型的挑战

在Java、C++或Python中，线程间通信通常依赖于共享内存。程序员们必须小心翼翼地使用锁来保护共享数据结构，从而避免竞争条件和死锁。比如Python的Queue，它是线程安全的，但仍然不能避免锁的争用问题。

# Python中使用队列的简单示例
from queue import Queue
from threading import Thread

def worker(q):
    while True:
        item = q.get()
        # 处理项目
        print(f'处理 {item}')
        q.task_done()

q = Queue()
for i in range(5):
    t = Thread(target=worker, args=(q,))
    t.daemon = True
    t.start()

for item in range(20):
    q.put(item)

q.join()  # 等待所有项被处理

2. Go的并发哲学

与传统模型不同，Go语言引入了goroutines和channels作为并发的基石。goroutines可以被看作是轻量级的线程，而channels则是它们之间的通信机制。

// Go中使用channel的简单示例
package main

import (
    "fmt"
    "time"
)

func worker(done chan bool) {
    fmt.Print("工作中...")
    time.Sleep(time.Second)
    fmt.Println("完成")

    // 发送信号
    done <- true
}

func main() {
    done := make(chan bool, 1)
    go worker(done)

    // 等待通知
    if <-done {
        fmt.Println("工作协程已通知结束。")
    }
}

3. Go的实践案例：URL轮询器

让我们通过一个URL轮询器的例子来看看Go是如何实践其并发哲学的。传统的线程模型中，我们可能需要保护数据结构以防止多线程访问。但在Go中，我们只需要简单地在goroutines之间传递数据。

// Go中的URL轮询器示例
type Resource string

func Poller(in, out chan *Resource) {
    for r := range in {
        // 模拟URL轮询过程
        fmt.Printf("轮询 %s\n", *r)
        // 将处理完的Resource发送到out
        out <- r
    }
}

// 使用goroutines和channels的URL轮询器
func main() {
    in := make(chan *Resource)
    out := make(chan *Resource)
    go Poller(in, out)
    // ... 其他逻辑
}