并发原语的使用 —— 面向仓颉的解读与工程实践

在仓颉这样的声明式、类型安全语言里，并发不是一个“加了几根线程就结束”的话题，而是涉及内存模型、所有权、可变性约束和调度语义的系统工程。并发原语（mutex、rwlock、channel、atomic、semaphore、barrier、future/task 等）是把并发复杂性封装为可组合工具的桥梁。本文从语义、常见场景、实践要点与反模式四个维度展开，给出仓颉风格的示例与工程建议，帮助你在真实项目中稳健使用并发原语。

并发原语的语义映射（在仓颉语境）

1. 互斥锁（Mutex）：用于保护可变共享状态的独占访问。仓颉鼓励把可变状态放到明确的 Owner（如 Arc<Mutex<T>>）下，借助类型系统避免无意复制。
2. 读写锁（RwLock）：适用于“读多写少”的共享：多个读者并发、写者独占。
3. 消息传递（Channel / Mailbox）：把数据所有权移交而非共享，符合仓颉“move/borrow”哲学，减少锁争用。
4. 原子操作（Atomic）：用于极细粒度的同步与无锁算法（计数器、状态标志），需理解内存序（SeqCst / Acquire / Release）。
5. 同步构件（Semaphore / Barrier / CondVar）：控制资源并发度（如连接池）、协调阶段性 barrier。
6. 异步任务与 await：async/await 将并发表达为调度友好的协作式并发，关键规则是不要在持锁时 await。

常见使用场景与实践要点

• 组件共享只读数据：优先使用不可变数据与 Arc<T>（或语言等价物），避免锁。只在需要写时用 RwLock。
• 事件驱动与 UI 更新：以消息传递为首选：组件向主线程发送事件（channel），主线程负责状态变更与渲染，避免跨线程直接操作 UI 状态。
• 任务池与长任务：用线程/任务池（worker pool）隔离 CPU 密集型与 I/O 密集型工作，防止阻塞异步调度器。
• 高频路径的锁优化：若某个计数器或标志在热路径，优先使用原子（AtomicU64 等）而非 Mutex，以降低上下文切换成本。
• 避免在回调/await 中持锁：在锁内做尽量少的工作，若必须 await，则先克隆必要的小数据或释放锁后再 await。
• 使用消息语义避免复杂同步：例如缓存更新、任务分派等用 channel 把所有权移动到消费者，减少锁层次。

设计与错误模式

• 死锁：避免嵌套锁（lock ordering）与循环等待。为复杂临界区定义全局加锁顺序或使用 try_lock + 后退重试策略。
• 优先级反转：低优先级持锁导致高优先级等待，注意在实时敏感场景中使用锁替代方案。
• 数据竞争与内存序误用：原子操作看似简单，但错误的内存序会导致难以复现的 bug。默认使用最强保证（SeqCst）直到有明确需要。
• 资源泄漏：长时间持有锁（如 I/O）会降低吞吐，使用 scoped/thread-local 模式限制生命周期。
• 闭包隐式捕获：spawn/async move 语义要显式，避免意外转移大对象所有权或造成生命周期延长。

仓颉风格实战代码（伪代码示例）

// 共享计数器：Arc + Atomic
val counter: Arc<AtomicU64> = Arc::new(AtomicU64::new(0))

spawn(async {
    for i in 0..1000 {
        counter.fetch_add(1, Ordering::SeqCst)
    }
})

// 使用 channel 做工作分发（消息传递）
val (tx, rx) = channel::<Job>(100)
spawn(|| worker(rx))

tx.send(job1)
tx.send(job2)

// Mutex 保护复杂状态（短持锁）
val state: Arc<Mutex<SharedState>> = Arc::new(Mutex::new(SharedState::new()))
{
    let mut s = state.lock()
    s.update_fast()    // 在临界区内只做小量同步工作
} // 立即释放锁

// 注意：不要在持锁时 await！

总结建议（工程实践清单）

1. 优先不可变与消息传递；共享可变时再用锁。
2. 在 API 层明确并发语义（谁是 Owner，谁会 clone/clone-cost）。
3. 对高频通路用原子或无锁结构；对复杂一致性用 Mutex + 小临界区。
4. 在异步代码中严格禁止“持锁 await”；用消息或复制小数据来解耦。
5. 编写死锁/竞争测试并使用工具（如线程 sanitizer）检验。

并发是把程序从“顺序世界”推向“多实体交互”的实践艺术。仓颉的类型系统、所有权与声明式模型为并发提供了强有力的静态约束；合理选择并发原语并把约束写入类型与接口，是把复杂性转化为可管控成本的关键。