Golang 채널 닫기 | 채널 동기화 (Channel Synchronization)

소개

Golang 에서 채널을 닫는 것은 채널 수신자에게 작업 완료를 알리는 데 사용될 수 있습니다. 이 랩에서는 채널을 사용하여 main() 고루틴에서 작업자 고루틴으로 수행할 작업을 전달하는 방법과, 작업자에게 더 이상 작업이 없을 때 채널을 닫는 방법을 보여줍니다.

채널 닫기

이 랩에서는 작업자에게 더 이상 작업이 없을 때 주어진 코드를 수정하여 jobs 채널을 닫아야 합니다. 또한 모든 작업이 완료되었을 때 알림을 보내기 위해 done 채널을 사용해야 합니다.

main() 고루틴에서 작업자 고루틴으로 수행할 작업을 전달하기 위해 버퍼링된 채널 jobs를 사용합니다.
모든 작업이 완료되었을 때 알림을 보내기 위해 채널 done을 사용합니다.
j, more := <-jobs를 사용하여 jobs에서 반복적으로 값을 수신하는 작업자 고루틴을 사용합니다.
모든 작업이 완료되었을 때 done에 알림을 보내기 위해 수신의 특수한 2-값 형식을 사용합니다.
jobs 채널을 통해 작업자에게 3 개의 작업을 보내고, 채널을 닫습니다.
동기화 방식을 사용하여 작업자를 기다립니다.

$ go run closing-channels.go
sent job 1
received job 1
sent job 2
received job 2
sent job 3
received job 3
sent all jobs
received all jobs

## The idea of closed channels leads naturally to our next
## example: `range` over channels.

전체 코드는 다음과 같습니다.

// _Closing_ a channel indicates that no more values
// will be sent on it. This can be useful to communicate
// completion to the channel's receivers.

package main

import "fmt"

// In this example we'll use a `jobs` channel to
// communicate work to be done from the `main()` goroutine
// to a worker goroutine. When we have no more jobs for
// the worker we'll `close` the `jobs` channel.
func main() {
    jobs := make(chan int, 5)
    done := make(chan bool)

    // Here's the worker goroutine. It repeatedly receives
    // from `jobs` with `j, more := <-jobs`. In this
    // special 2-value form of receive, the `more` value
    // will be `false` if `jobs` has been `close`d and all
    // values in the channel have already been received.
    // We use this to notify on `done` when we've worked
    // all our jobs.
    go func() {
        for {
            j, more := <-jobs
            if more {
                fmt.Println("received job", j)
            } else {
                fmt.Println("received all jobs")
                done <- true
                return
            }
        }
    }()

    // This sends 3 jobs to the worker over the `jobs`
    // channel, then closes it.
    for j := 1; j <= 3; j++ {
        jobs <- j
        fmt.Println("sent job", j)
    }
    close(jobs)
    fmt.Println("sent all jobs")

    // We await the worker using the
    // [synchronization](channel-synchronization) approach
    // we saw earlier.
    <-done
}

요약

이 랩에서는 채널을 사용하여 main() 고루틴에서 작업자 고루틴으로 수행할 작업을 전달하는 방법과, 작업자에게 더 이상 작업이 없을 때 채널을 닫는 방법을 배웠습니다. 또한 모든 작업이 완료되었을 때 알림을 보내기 위해 done 채널을 사용하는 방법도 배웠습니다.

Golang 채널을 이용한 작업자 통신

소개

채널 닫기

요약