zig-concurrency

Files (1)

• SKILL.md

SKILL.md (first lines)

# Zig 并发编程

> 基于 std.Thread 和 std.atomic 的并发原语（Zig 0.16.0）。

## Capability Boundaries

### ✅ 强项
1. 线程创建与管理（spawn、join、detach）
2. 同步原语（Mutex、RwLock、Condition、Semaphore、ResetEvent、WaitGroup）
3. 线程池（Thread.Pool）用于并行任务
4. 原子操作（std.atomic.Value）
5. 常见并发模式（生产者-消费者、工作队列）

### ⚠️ 前置要求
1. 确认 Zig 版本（`zig version`）
2. 理解基本并发概念（竞态条件、死锁）

### ❌ 不适用范围
1. 异步 I/O → 使用 `zig-http` 或 `zig-0.16` 的 std.Io
2. 非并发场景 → 使用 `zig-0.16` 技能

## 何时使用

- "多线程处理数据"
- "并行执行多个任务"
- "线程安全的共享状态"

## Data Privacy

本技能不收集、存储或传输任何用户数据。

## Workflow

步骤 1. **识别并发需求** — CPU 密集 / I/O 等待 / 并行计算？
步骤 2. **选择原语** — 线程 / 线程池 / 原子操作？
步骤 3. **实现同步** — Mutex / RwLock / WaitGroup
步骤 4. **测试正确性** — 竞态条件、死锁检查

## 模块总览

```zig
std.Thread                  // 线程创建与管理
std.Thread.Mutex            // 互斥锁
std.Thread.Mutex.Recursive  // 可重入互斥锁
std.Thread.RwLock           // 读写锁
std.Thread.Condition        // 条件变量
std.Thread.Semaphore        // 计数信号量
std.Thread.ResetEvent       // 布尔事件标志（阻塞式）
std.Thread.WaitGroup        // 等待多任务完成
std.Thread.Pool             // 线程池
std.Thread.Futex            // 底层 futex（高级）
std.atomic.Value(T)         // 原子类型包装
```

## 线程创建

### 基本线程
```zig
fn worker(id: usize) void {
    std.debug.print("Worker {d}\n", .{id});
}

const thread = try std.Thread.spawn(.{}, worker, .{42});
thread.join();  // 等待完成
```

### 带分配器配置
```zig
const thread = try std.Thread.spawn(.{ .allocator = allocator }, worker, .{42});
defer thread.join();
```

### 分离线程（不 join）
```zig
const thread = try std.Thread.spawn(.{}, worker, .{1});
thread.detach();  // 线程自动清理
```

## 同步原语

### Mutex（互斥锁）
```zig
var mutex: std.Thread.Mutex = .{};
var shared: i32 = 0;

fn increment() void {
    mutex.lock();
    defer mutex.unlock();
    shared += 1;
}
```

### RwLock（读写锁）
```zig
var rwlock: std.Thread.RwLock = .{};
var data: i32 = 0;

fn reader() void {
    rwlock.lockShared();
    defer rwlock.unlockShared();
    _ = data;  // 可并发读
}

fn writer() void {
    rwlock.lock();
    defer rwlock.unlock();
    data += 1;  // 独占写
}
```

### Condition（条件变量）
```zig
var mutex: std.Thread.Mutex = .{};
var cond: std.Thread.Condition = .{};
var ready: bool = false;

fn waiter() void {
    mutex.lock();
    defer mutex.unlock();

From Yabuku-xD/omfx, MIT.

More from Yabuku-xD/omfx