并发模式实战指南：多线程、异步编程与并行数据处理最佳实践

concurrency-patterns by aj-geddes/useful-ai-prompts

164 周安装量

160 GitHub Stars

GitHub

安装命令

npx skills add https://github.com/aj-geddes/useful-ai-prompts --skill concurrency-patterns

开发自动化性能优化

🇨🇳中文介绍

并发模式

概述

使用适当的同步原语和并行执行模式来实现安全的并发代码。

适用场景

多线程应用程序
并行数据处理
竞态条件预防
资源池化
任务协调
高性能系统
异步操作
工作线程池

快速开始

最小工作示例：

class PromisePool {
  private queue: Array<() => Promise<any>> = [];
  private active = 0;

  constructor(private concurrency: number) {}

  async add<T>(fn: () => Promise<T>): Promise<T> {
    while (this.active >= this.concurrency) {
      await this.waitForSlot();
    }

    this.active++;

    try {
      return await fn();
    } finally {
      this.active--;
    }
  }

  private async waitForSlot(): Promise<void> {
    return new Promise((resolve) => {
      const checkSlot = () => {
        if (this.active < this.concurrency) {
          resolve();
// ... (完整实现请参阅参考指南)

参考指南

references/ 目录下的详细实现：

广告位招租

在这里展示您的产品或服务

触达数万 AI 开发者，精准高效

联系我们

指南	内容
Promise Pool (TypeScript)	Promise 池 (TypeScript)
Mutex and Semaphore (TypeScript)	互斥锁与信号量 (TypeScript)
Worker Pool (Node.js)	工作线程池 (Node.js)
Python Threading Patterns	Python 线程模式
Async Patterns (Python asyncio)	异步模式 (Python asyncio)
Go-Style Channels (Simulation)	Go 风格通道 (模拟)

🇺🇸English

Concurrency Patterns

Overview
When to Use
Quick Start
Reference Guides
Best Practices

Overview

Implement safe concurrent code using proper synchronization primitives and patterns for parallel execution.

When to Use

Multi-threaded applications
Parallel data processing
Race condition prevention
Resource pooling
Task coordination
High-performance systems
Async operations
Worker pools

Quick Start

Minimal working example:

class PromisePool {
  private queue: Array<() => Promise<any>> = [];
  private active = 0;

  constructor(private concurrency: number) {}

  async add<T>(fn: () => Promise<T>): Promise<T> {
    while (this.active >= this.concurrency) {
      await this.waitForSlot();
    }

    this.active++;

    try {
      return await fn();
    } finally {
      this.active--;
    }
  }

  private async waitForSlot(): Promise<void> {
    return new Promise((resolve) => {
      const checkSlot = () => {
        if (this.active < this.concurrency) {
          resolve();
// ... (see reference guides for full implementation)

Reference Guides

Detailed implementations in the references/ directory:

Guide	Contents
Promise Pool (TypeScript)	Promise Pool (TypeScript)
Mutex and Semaphore (TypeScript)	Mutex and Semaphore (TypeScript)
Worker Pool (Node.js)	Worker Pool (Node.js)
Python Threading Patterns	Python Threading Patterns
Async Patterns (Python asyncio)	Async Patterns (Python asyncio)
Go-Style Channels (Simulation)	Go-Style Channels (Simulation)

Best Practices

✅ DO

Use proper synchronization primitives
Limit concurrency to avoid resource exhaustion
Handle errors in concurrent operations
Use immutable data when possible
Test concurrent code thoroughly
Profile concurrent performance
Document thread-safety guarantees

❌ DON'T

Share mutable state without synchronization
Use sleep/polling for coordination
Create unlimited threads/workers
Ignore race conditions
Block event loops in async code
Forget to clean up resources

Weekly Installs

119

Repository

aj-geddes/usefu…-prompts

GitHub Stars

121

First Seen

Jan 21, 2026

Security Audits

Gen Agent Trust HubPass SocketPass SnykPass

Installed on

opencode100

gemini-cli98

codex96

claude-code93

cursor91

github-copilot82