Python Channels: CSP Concurrency & Pipelines

In Plain English

Go follows Hoare Communicating Sequential Processes (CSP). Channels provide typed synchronization conduits between goroutines. Master unbuffered vs buffered channels, channel closing, and pipeline streaming.

The Mental Model

"An unbuffered channel is handing a baton in a relay race—both runners must meet at the exact same instant. A buffered channel is a mail drop box with fixed slots."

Deep Dive: How It Works

CSP Philosophy: "Do not communicate by sharing memory; instead, share memory by communicating."

Unbuffered Channels: Synchronous rendezvous where send blocks until receiver is ready and vice versa.

Buffered Channels: Non-blocking until internal buffer capacity is full.

Range over Channels: for v := range ch drains values until sender calls close(ch).

Syntax Blueprint

ch := make(chan int, 2)
ch <- 42
val := <-ch
close(ch)

Create buffered/unbuffered channels with make, send with <-, receive with <-, and close with close().

Core Rules to Remember

Synchronization Conduit: Channels transfer data and ownership safely across goroutines without manual mutexes.

Sender Closes: Only the sender should close a channel to signal that no more items will arrive.

Directional Channels: Use chan<- T (send-only) and <-chan T (receive-only) in function signatures.

Common Beginner Traps & How to Fix Them

Mistake:Sending to a closed channel: close(ch); ch <- 1.

Why it happens: Sending to or closing a closed channel triggers an immediate runtime panic.

How to fix: Ensure only the producer closes the channel once.

Pro Tip: Use unbuffered channels when you need immediate synchronization guarantees, and buffered channels when decoupling producer/consumer bursts.

Live Interactive Example

Hit Run Code to see it live

Producer-Consumer Number Pipeline

Go 1.22 / Runtime

Output Console

Click "Run Code" to view the rendered output.

How it works: for num := range ch received each integer until produce called close(ch).

Your Turn: Micro Challenge

No pressure! Edit the starter code below and test your solution with instant feedback.

Micro Exercise

Sum Numbers through a Channel

Write a function sumWorker(nums []int, out chan<- int) that calculates the sum of a slice and sends it to out.
In main(), launch sumWorker on slice [10, 20, 30] in a goroutine.
Receive the sum from the channel and print "Total: %d".

Sandbox Output

Click "Run & Check" to test your solution.

Finished reading and practicing?

Mark this lesson as completed to update your course progress.