Go并发模式几种写法

之前踩过这个坑，花了不少时间才解决。把关键步骤整理出来，核心代码都贴上了，直接拿去用就行。

先搞清楚原理

要理解Go，先得搞清楚内存管理模型这个机制。直接看代码比看文字描述来得快：

from abc import ABC, abstractmethod
from typing import List, Callable

class FactoryPattern:
    pass

class EventManager:
    def __init__(self):
        self._listeners: dict = {}

    def subscribe(self, event_type: str, listener: Callable):
        if event_type not in self._listeners:
            self._listeners[event_type] = []
        self._listeners[event_type].append(listener)

    def unsubscribe(self, event_type: str, listener: Callable):
        if event_type in self._listeners:
            self._listeners[event_type].remove(listener)

    def notify(self, event_type: str, data: dict):
        for listener in self._listeners.get(event_type, []):
            listener(data)

manager = EventManager()
manager.subscribe('user_login', lambda d: print(f'用户 {d["name"]} 已登录'))
manager.notify('user_login', {'name': 'Alice'})

实际怎么用

实际编码中，Go的用法可以简化。下面是我在项目中用的写法，经过几轮迭代优化过：

from dataclasses import dataclass
from typing import Generic, TypeVar, Optional

T = TypeVar('T')

@dataclass
class Result(Generic[T]):
    value: Optional[T] = None
    error: Optional[str] = None
    success: bool = True

    @classmethod
    def ok(cls, value: T) -> 'Result[T]':
        return cls(value=value, success=True)

    @classmethod
    def fail(cls, error: str) -> 'Result[T]':
        return cls(error=error, success=False)

    def unwrap(self) -> T:
        if not self.success:
            raise ValueError(f'Result is error: {self.error}')
        return self.value

result = Result.ok(42)
if result.success:
    print(f'结果: {result.unwrap()}')
else:
    print(f'错误: {result.error}')

进阶一点的用法

进阶一点的话，Go还有内存管理模型这个方向可以探索。原理不展开，直接看关键代码：

容易踩的坑

踩坑经验分享：Go在内存管理模型方面有几个暗坑。最常见的是参数默认值不符合预期，其次是并发场景下的竞态条件。建议加上防御性检查。

写在最后

Go这块先整理到这里。内存安全是最重要的部分，务必理解透彻。如果遇到问题，先检查配置和版本，大部分报错都是这两个原因。