channels/

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

Links

Open Source Insights

README ¶

Channels

Channels allow goroutines to communicate with each other through the use of signaling semantics. Channels accomplish this signaling through the use of sending/receiving data or by identifying state changes on individual channels. Don't architect software with the idea of channels being a queue, focus on signaling and the semantics that simplify the orchestration required.

Design Guidelines

Learn about the design guidelines for channels.

Diagrams

Guarantee Of Delivery

The Guarantee Of Delivery is based on one question: “Do I need a guarantee that the signal sent by a particular goroutine has been received?”

Ardan Labs

Signaling With Or Without Data

When you are going to signal with data, there are three channel configuration options you can choose depending on the type of guarantee you need.

Ardan Labs

Signaling without data serves the main purpose of cancellation. It allows one goroutine to signal another goroutine to cancel what they are doing and move on. Cancellation can be implemented using both unbuffered and buffered channels.

Ardan Labs

State

The behavior of a channel is directly influenced by its current State. The state of a channel can be nil, open or closed.

Ardan Labs

Links

The Behavior Of Channels - William Kennedy
Channel Communication
Share Memory By Communicating - Andrew Gerrand
The Nature Of Channels In Go - William Kennedy
A Retrospective on SEDA - Matt Welsh
Understanding Channels - Kavya Joshi

Buffer Bloat - 2011

Large buffers prevent timely notification of back pressure.
They defeat your ability to reduce back pressure in a timely matter.
They can increase latency not reduce it.
Use buffered channels to provide a way of maintaining continuity.
- Don't use them just for performance.
- Use them to handle well defined bursts of data.
- Use them to deal with speed of light issues between handoffs.

Bufferbloat: Dark Buffers in the Internet
Buffer Bloat Videos

Code Review

Basic mechanics (Go Playground)
Tennis game (Go Playground)
Relay race (Go Playground)
Fan out pattern (Go Playground)
Monitor running time (Go Playground)

Advanced Code Review

Channel communication ordering (Go Playground)

Exercises

Exercise 1

Write a program where two goroutines pass an integer back and forth ten times. Display when each goroutine receives the integer. Increment the integer with each pass. Once the integer equals ten, terminate the program cleanly.

Template (Go Playground) | Answer (Go Playground)

Exercise 2

Write a program that uses a fan out pattern to generate 100 random numbers concurrently. Have each goroutine generate a single random number and return that number to the main goroutine over a buffered channel. Set the size of the buffer channel so no send ever blocks. Don't allocate more buffers than you need. Have the main goroutine display each random number it receives and then terminate the program.

Template (Go Playground) | Answer (Go Playground)

Exercise 3

Write a program that generates up to 100 random numbers concurrently. Do not send all 100 values so the number of sends/receives is unknown.

Template (Go Playground) | Answer (Go Playground)

Exercise 4

Write a program that generates up to 100 random numbers concurrently using a worker pool. Reject even values. Instruct the workers to shutdown with 100 odd numbers have been collected.

Template (Go Playground) | Answer (Go Playground)

All material is licensed under the Apache License Version 2.0, January 2004.

Directories ¶

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Path	Synopsis
advanced
example1 Sample program to show the order of channel communication for unbuffered, buffered and closing channels based on the specification.	Sample program to show the order of channel communication for unbuffered, buffered and closing channels based on the specification.
example1 This sample program demonstrates the basic channel mechanics for goroutine signaling.	This sample program demonstrates the basic channel mechanics for goroutine signaling.
example2 Sample program to show how to use an unbuffered channel to simulate a game of tennis between two goroutines.	Sample program to show how to use an unbuffered channel to simulate a game of tennis between two goroutines.
example3 Sample program to show how to use an unbuffered channel to simulate a relay race between four goroutines.	Sample program to show how to use an unbuffered channel to simulate a relay race between four goroutines.
example4 This sample program demonstrates how to use a buffered channel to receive results from other goroutines in a guaranteed way.	This sample program demonstrates how to use a buffered channel to receive results from other goroutines in a guaranteed way.
example5 This sample program demonstrates how to use a channel to monitor the amount of time the program is running and terminate the program if it runs too long.	This sample program demonstrates how to use a channel to monitor the amount of time the program is running and terminate the program if it runs too long.
exercises
exercise1 Write a program where two goroutines pass an integer back and forth ten times.	Write a program where two goroutines pass an integer back and forth ten times.
exercise2 Write a program that uses a fan out pattern to generate 100 random numbers concurrently.	Write a program that uses a fan out pattern to generate 100 random numbers concurrently.
exercise3 Write a program that uses goroutines to generate up to 100 random numbers.	Write a program that uses goroutines to generate up to 100 random numbers.
exercise4 Write a program that creates a fixed set of workers to generate random numbers.	Write a program that creates a fixed set of workers to generate random numbers.
template1 Write a program where two goroutines pass an integer back and forth ten times.	Write a program where two goroutines pass an integer back and forth ten times.
template2 Write a program that uses a fan out pattern to generate 100 random numbers concurrently.	Write a program that uses a fan out pattern to generate 100 random numbers concurrently.
template3 Write a program that uses goroutines to generate up to 100 random numbers.	Write a program that uses goroutines to generate up to 100 random numbers.
template4 Write a program that creates a fixed set of workers to generate random numbers.	Write a program that creates a fixed set of workers to generate random numbers.