From c
C语言并发编程规范，涵盖C11原子操作与内存序、pthread线程管理、互斥锁、条件变量、读写锁、ThreadSanitizer竞态检测。适用于多线程开发、死锁调试、无锁数据结构优化。
npx claudepluginhub lazygophers/ccplugin --plugin cThis skill uses the workspace's default tool permissions.
- **dev** - 实现并发数据结构和多线程逻辑
Searches, retrieves, and installs Agent Skills from prompts.chat registry using MCP tools like search_skills and get_skill. Activates for finding skills, browsing catalogs, or extending Claude.
Searches prompts.chat for AI prompt templates by keyword or category, retrieves by ID with variable handling, and improves prompts via AI. Use for discovering or enhancing prompts.
Guides MCP server integration in Claude Code plugins via .mcp.json or plugin.json configs for stdio, SSE, HTTP types, enabling external services as tools.
| 场景 | Skill | 说明 |
|---|---|---|
| 核心规范 | Skills(c:core) | C11 标准、_Atomic 关键字 |
| 内存管理 | Skills(c:memory) | 线程安全分配、内存池 |
| POSIX API | Skills(c:posix) | pthread API |
| AI 理性化 | 实际检查 |
|---|---|
| "单线程不需要原子操作" | 未来是否可能多线程化？ |
| "这个 race 不会触发" | 是否用 TSan 验证了？ |
| "memory_order_relaxed 够了" | 是否有 happens-before 依赖？ |
| "不需要锁，速度更快" | 无锁逻辑是否正确？ |
| "信号处理器里可以用 mutex" | 信号处理器是否只用 async-signal-safe 函数？ |
#include <stdatomic.h>
// 声明
_Atomic int counter = 0; // C11 关键字
atomic_int counter2 = 0; // 等价 typedef
// 基本操作
atomic_store(&counter, 42);
int val = atomic_load(&counter);
int old = atomic_fetch_add(&counter, 1); // 返回旧值
atomic_fetch_sub(&counter, 1);
// CAS（Compare-And-Swap）
int expected = 0;
bool success = atomic_compare_exchange_strong(&counter, &expected, 1);
// weak 版本允许虚假失败，循环中使用更高效
while (!atomic_compare_exchange_weak(&counter, &expected, new_val)) {
expected = atomic_load(&counter);
}
// 从松到严：relaxed < acquire/release < seq_cst
atomic_store_explicit(&flag, 1, memory_order_release); // 发布
int f = atomic_load_explicit(&flag, memory_order_acquire); // 获取
// relaxed：仅保证原子性，无顺序保证（计数器场景）
atomic_fetch_add_explicit(&counter, 1, memory_order_relaxed);
// seq_cst（默认）：最严格，全序一致
atomic_store(&flag, 1); // 默认 seq_cst
#include <threads.h>
int worker(void* arg) {
int id = *(int*)arg;
// 工作逻辑
return 0;
}
int main(void) {
thrd_t threads[4];
int ids[4] = {0, 1, 2, 3};
for (int i = 0; i < 4; i++) {
if (thrd_create(&threads[i], worker, &ids[i]) != thrd_success) {
fprintf(stderr, "Failed to create thread %d\n", i);
return EXIT_FAILURE;
}
}
for (int i = 0; i < 4; i++) {
int result;
thrd_join(threads[i], &result);
}
return EXIT_SUCCESS;
}
#include <pthread.h>
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
// 互斥锁保护
pthread_mutex_lock(&mutex);
shared_data++;
pthread_mutex_unlock(&mutex);
// 条件变量（必须在循环中等待，防止虚假唤醒）
pthread_mutex_lock(&mutex);
while (!ready) {
pthread_cond_wait(&cond, &mutex);
}
// 处理数据
pthread_mutex_unlock(&mutex);
// 通知
pthread_mutex_lock(&mutex);
ready = true;
pthread_cond_signal(&cond); // 唤醒一个 / broadcast 唤醒所有
pthread_mutex_unlock(&mutex);
// 清理
pthread_mutex_destroy(&mutex);
pthread_cond_destroy(&cond);
pthread_rwlock_t rwlock = PTHREAD_RWLOCK_INITIALIZER;
// 读锁（多个读者并发）
pthread_rwlock_rdlock(&rwlock);
int val = shared_data;
pthread_rwlock_unlock(&rwlock);
// 写锁（独占）
pthread_rwlock_wrlock(&rwlock);
shared_data = new_val;
pthread_rwlock_unlock(&rwlock);
pthread_rwlock_destroy(&rwlock);
# 编译启用 TSan（不可与 ASan 同时使用）
gcc -std=c17 -fsanitize=thread -g -O1 program.c -o program -lpthread
# 运行，TSan 自动报告竞态
./program
# 典型报告：WARNING: ThreadSanitizer: data race