为元胞自动机实现Observer/发布订阅模式及异常排查

核心问题点 #

• 缺少元胞自动机必需的步次同步机制
  你当前的实现是事件驱动的即时转发逻辑，不符合元胞自动机的同步更新规则：元胞自动机所有节点的状态更新是批量同步的，必须先收集齐当前步次所有邻居的输入，再统一计算本节点下一个步次的状态，最后统一广播给邻居。你现在收到任意一个邻居的消息就立刻转发，同一步次的多个输入会被重复处理，消息数量指数级膨胀，最终所有goroutine都卡在通道操作上，表现为数值不再增长。
  2节点版本可以正常运行，是因为每个节点只有一个输入，不存在多输入重复处理的问题。

• 无缓冲通道导致发送阻塞
  你所有的通道都是无缓冲的，发送方执行ch <- val时必须等待接收方刚好执行到<-ch才能完成发送。消息膨胀后，goroutine调度顺序的差异会导致大量发送操作被阻塞，程序直接假死。

• 无重复消息合并逻辑
  4节点是环形拓扑，同一步次的消息会沿顺时针、逆时针两个方向传播到同一个节点。你没有给消息加步次标记，无法判断收到的多个消息是否属于同一步次，重复处理进一步加剧了消息膨胀的速度。

修复建议 #

1. 给消息增加步次编号字段，每个节点维护当前已处理的最大步次，收到步次小于等于当前最大步次的消息直接丢弃，避免重复处理。
2. 修改节点逻辑，按步次收集左右邻居的输入，收齐同一步次的两个输入后，再计算本节点下一个状态，广播时携带新的步次编号。
3. 初始化所有通道时增加适当缓冲（比如make(chan int, 16)），避免调度差异导致的意外阻塞。

内容的提问来源于stack exchange，提问作者Serge Hulne