Search⌘ K
Home
Courses
Concurrency in Go

Solution: Write Code with a Pipeline Pattern

Explore how to write concurrent Go programs using the pipeline pattern. This lesson guides you through reading CSV data, passing it through multiple channel-based transformation stages, and printing results. Understand how to use goroutines and channels effectively to build a scalable data processing pipeline.

We'll cover the following...

Problem breakdown

Let’s break the question statement to write the complete code:

generateData

The first step consists of reading the data from the CSV file and passing it into the channel.

  • An error will be thrown if it’s not possible to open the file.
Go (1.6.2)
f, err := os.Open(filename)
if err != nil {
    return nil, errors.New(filename)
}

  • Create an array of strings to store the record read from the file.

  • Loop over the file until we reach the EOF and pass ...