← 返回 Skills 市场
samber

Golang Concurrency

作者 Samuel Berthe · GitHub ↗ · v1.1.1 · MIT-0
cross-platform ✓ 安全检测通过
185
总下载
0
收藏
0
当前安装
2
版本数
在 OpenClaw 中安装
/install golang-concurrency
功能描述
Golang concurrency patterns. Use when writing or reviewing concurrent Go code involving goroutines, channels, select, locks, sync primitives, errgroup, singl...
使用说明 (SKILL.md)

Persona: You are a Go concurrency engineer. You assume every goroutine is a liability until proven necessary — correctness and leak-freedom come before performance.

Modes:

  • Write mode — implement concurrent code (goroutines, channels, sync primitives, worker pools, pipelines). Follow the sequential instructions below.
  • Review mode — reviewing a PR's concurrent code changes. Focus on the diff: check for goroutine leaks, missing context propagation, ownership violations, and unprotected shared state. Sequential.
  • Audit mode — auditing existing concurrent code across a codebase. Use up to 5 parallel sub-agents as described in the "Parallelizing Concurrency Audits" section.

Community default. A company skill that explicitly supersedes samber/cc-skills-golang@golang-concurrency skill takes precedence.

Go Concurrency Best Practices

Go's concurrency model is built on goroutines and channels. Goroutines are cheap but not free — every goroutine you spawn is a resource you must manage. The goal is structured concurrency: every goroutine has a clear owner, a predictable exit, and proper error propagation.

Core Principles

  1. Every goroutine must have a clear exit — without a shutdown mechanism (context, done channel, WaitGroup), they leak and accumulate until the process crashes
  2. Share memory by communicating — channels transfer ownership explicitly; mutexes protect shared state but make ownership implicit
  3. Send copies, not pointers on channels — sending pointers creates invisible shared memory, defeating the purpose of channels
  4. Only the sender closes a channel — closing from the receiver side panics if the sender writes after close
  5. Specify channel direction (chan\x3C-, \x3C-chan) — the compiler prevents misuse at build time
  6. Default to unbuffered channels — larger buffers mask backpressure; use them only with measured justification
  7. Always include ctx.Done() in select — without it, goroutines leak after caller cancellation
  8. Never use time.After in loops — each call creates a timer that lives until it fires, accumulating memory. Use time.NewTimer + Reset
  9. Track goroutine leaks in tests with go.uber.org/goleak

For detailed channel/select code examples, see Channels and Select Patterns.

Channel vs Mutex vs Atomic

Scenario Use Why
Passing data between goroutines Channel Communicates ownership transfer
Coordinating goroutine lifecycle Channel + context Clean shutdown with select
Protecting shared struct fields sync.Mutex / sync.RWMutex Simple critical sections
Simple counters, flags sync/atomic Lock-free, lower overhead
Many readers, few writers on a map sync.Map Optimized for read-heavy workloads. Concurrent map read/write causes a hard crash
Caching expensive computations sync.Once / singleflight Execute once or deduplicate

WaitGroup vs errgroup

Need Use Why
Wait for goroutines, errors not needed sync.WaitGroup Fire-and-forget
Wait + collect first error errgroup.Group Error propagation
Wait + cancel siblings on first error errgroup.WithContext Context cancellation on error
Wait + limit concurrency errgroup.SetLimit(n) Built-in worker pool

Sync Primitives Quick Reference

Primitive Use case Key notes
sync.Mutex Protect shared state Keep critical sections short; never hold across I/O
sync.RWMutex Many readers, few writers Never upgrade RLock to Lock (deadlock)
sync/atomic Simple counters, flags Prefer typed atomics (Go 1.19+): atomic.Int64, atomic.Bool
sync.Map Concurrent map, read-heavy No explicit locking; use RWMutex+map when writes dominate
sync.Pool Reuse temporary objects Always Reset() before Put(); reduces GC pressure
sync.Once One-time initialization Go 1.21+: OnceFunc, OnceValue, OnceValues
sync.WaitGroup Wait for goroutine completion Add before go; Go 1.24+: wg.Go() simplifies usage
x/sync/singleflight Deduplicate concurrent calls Cache stampede prevention
x/sync/errgroup Goroutine group + errors SetLimit(n) replaces hand-rolled worker pools

For detailed examples and anti-patterns, see Sync Primitives Deep Dive.

Concurrency Checklist

Before spawning a goroutine, answer:

  • How will it exit? — context cancellation, channel close, or explicit signal
  • Can I signal it to stop? — pass context.Context or done channel
  • Can I wait for it?sync.WaitGroup or errgroup
  • Who owns the channels? — creator/sender owns and closes
  • Should this be synchronous instead? — don't add concurrency without measured need

Pipelines and Worker Pools

For pipeline patterns (fan-out/fan-in, bounded workers, generator chains, Go 1.23+ iterators, samber/ro), see Pipelines and Worker Pools.

Parallelizing Concurrency Audits

When auditing concurrency across a large codebase, use up to 5 parallel sub-agents (Agent tool):

  1. Find all goroutine spawns (go func, go method) and verify shutdown mechanisms
  2. Search for mutable globals and shared state without synchronization
  3. Audit channel usage — ownership, direction, closure, buffer sizes
  4. Find time.After in loops, missing ctx.Done() in select, unbounded spawning
  5. Check mutex usage, sync.Map, atomics, and thread-safety documentation

Common Mistakes

Mistake Fix
Fire-and-forget goroutine Provide stop mechanism (context, done channel)
Closing channel from receiver Only the sender closes
time.After in hot loop Reuse time.NewTimer + Reset
Missing ctx.Done() in select Always select on context to allow cancellation
Unbounded goroutine spawning Use errgroup.SetLimit(n) or semaphore
Sharing pointer via channel Send copies or immutable values
wg.Add inside goroutine Call Add before goWait may return early otherwise
Forgetting -race in CI Always run go test -race ./...
Mutex held across I/O Keep critical sections short

Cross-References

  • -> See samber/cc-skills-golang@golang-performance skill for false sharing, cache-line padding, sync.Pool hot-path patterns
  • -> See samber/cc-skills-golang@golang-context skill for cancellation propagation and timeout patterns
  • -> See samber/cc-skills-golang@golang-safety skill for concurrent map access and race condition prevention
  • -> See samber/cc-skills-golang@golang-troubleshooting skill for debugging goroutine leaks and deadlocks
  • -> See samber/cc-skills-golang@golang-design-patterns skill for graceful shutdown patterns
  • -> See samber/cc-skills-golang@golang-continuous-integration skill for automated AI-driven code review in CI using these guidelines

References

安全使用建议
This skill appears coherent for reviewing and writing concurrent Go code. Before installing, consider: (1) it can run commands (go, linters, git) and read/modify repository files — run it in a workspace you trust or a sandbox; (2) it does not request secrets or network endpoints, but git commands could use your configured credentials if the agent runs remote operations — restrict network/git access if unwanted; (3) verify the skill origin (homepage provided) if you need provenance; and (4) if you prefer human-only invocation, disable autonomous invocation or set the skill to user-invocable only.
功能分析
Type: OpenClaw Skill Name: golang-concurrency Version: 1.1.1 The skill bundle is a comprehensive and well-structured guide for Go concurrency engineering. It provides high-quality technical instructions for writing, reviewing, and auditing concurrent Go code, focusing on best practices like structured concurrency, avoiding goroutine leaks, and proper use of sync primitives. The requested tool permissions (Bash for go, golangci-lint, and git) are appropriate for its stated purpose, and no indicators of data exfiltration, malicious execution, or harmful prompt injection were found across the documentation or evaluation files.
能力评估
Purpose & Capability
Name/description (Go concurrency patterns, reviews, audits) match the declared needs: it only requires the 'go' binary and the ability to read project files; examples, references, and tests are all about concurrency patterns.
Instruction Scope
SKILL.md directs the agent to write/review/audit code and to read repository files and diffs (expected). It also describes running audits with up to 5 parallel sub-agents and allows running tools like git, go, and linters — normal for this use case but worth noting because the agent will have capability to read and modify repository files and run build/test commands.
Install Mechanism
Instruction-only skill with no install spec and no downloaded artifacts; nothing is written to disk by the skill itself beyond what the agent normally does.
Credentials
No environment variables, secrets, or unrelated credentials are requested. The declared single binary requirement ('go') is appropriate for running tests, linters, or examples.
Persistence & Privilege
always:false (not forced into every agent run). The skill permits autonomous invocation (disable-model-invocation:false) which is standard for skills; combined with allowed-tools this means the agent can run git/go/linter commands when invoked — expected for a code-review/write skill.
如何使用
  1. 确保已安装 OpenClaw(本地或 Docker 部署)
  2. 在对话框中输入安装命令:/install golang-concurrency
  3. 安装完成后,直接呼叫该 Skill 的名称或使用 /golang-concurrency 触发
  4. 根据 Skill 的参数说明提供必要输入,即可获得结构化输出
版本历史
v1.1.1
- Bumped version to 1.1.1 in metadata. - No changes to functionality or documentation content.
v1.1.0
- Comprehensive documentation added with best practices, checklists, and anti-patterns for Go concurrency. - Clear descriptions of skill persona, usage modes (Write, Review, Audit), and parallel audit capabilities. - Detailed tables and decision guides for choosing between channels, mutexes, atomic, sync primitives, and errgroup. - Practical checklists for goroutine management, structured shutdowns, and race-condition prevention. - Includes quick cross-references to related skills and official Go concurrency resources.
元数据
Slug golang-concurrency
版本 1.1.1
许可证 MIT-0
累计安装 0
当前安装数 0
历史版本数 2
常见问题

Golang Concurrency 是什么?

Golang concurrency patterns. Use when writing or reviewing concurrent Go code involving goroutines, channels, select, locks, sync primitives, errgroup, singl... 它是一个面向 Claude Code / OpenClaw 的 AI Agent Skill 插件,目前累计下载 185 次。

如何安装 Golang Concurrency?

在 OpenClaw 或 Claude Code 对话框中运行命令「/install golang-concurrency」即可一键安装,无需额外配置。

Golang Concurrency 是免费的吗?

是的,Golang Concurrency 完全免费,采用 MIT-0 许可证,可自由下载、安装和使用。

Golang Concurrency 支持哪些平台?

Golang Concurrency 跨平台运行,可在任意部署了 OpenClaw / Claude Code 的环境中使用(cross-platform)。

谁开发了 Golang Concurrency?

由 Samuel Berthe(@samber)开发并维护,当前版本 v1.1.1。

💬 留言讨论