package main

import (

	"fmt"

)

func main() {

	jobs := make(chan int, 5)

	done := make(chan bool)

	go func() {

		for {

			//读取通道方式, val,ok := <-chan 通道关闭后，ok是false

			j, more := <-jobs

			if more {

				fmt.Println("received job", j)

			} else {

				fmt.Println("received all jobs")

				done <- true

				return

			}

		}

	}()

	for j := 1; j <= 3; j++ {

		jobs <- j

		fmt.Println("sent job", j)

	}

	//关闭通道

	close(jobs)

	fmt.Println("sent all jobs")

	<-done

}