Basic channels example in go

channels_example.go

package main

import (
	"fmt"
	"time"
)

func main() {
	t := NewTest()
	// call methods on separate goroutines
	go t.C()
	go t.B()
	go t.A()

	// allow code to run 
	time.Sleep(1 * time.Second)
}

type Test struct {
	foo chan string
	bar chan string
}

func NewTest() *Test {
	// init channels
	return &Test{
		foo: make(chan string),
		bar: make(chan string),
	}
}
func (t *Test) A() {
	fmt.Println("func A")
	t.foo <- "a"
	t.foo <- "b"
	t.foo <- "c"
	t.foo <- "d"
	t.foo <- "e"
	t.foo <- "f"
}

func (t *Test) B() {
	str := ""
	fmt.Println("func B")
	// run for ever
	for {
		select
		{
			// read item from channel 		
			case s := <-t.foo:
				{
					str += s

					if len(str)%3 == 0 {
						t.bar <- str
						str = ""
					}
				}
		}
	}
}

func (t *Test) C() {
	fmt.Println("func C")
	for {
		select
		{
			case s := <-t.bar:
				fmt.Println(s)
			}
		}
}