모든 작업이 완료되면 여러 고루틴으로 채워진 채널을 어떻게 닫나요?

모든 작업이 완료되었을 때 여러 고루틴으로 채워진 채널을 닫는 방법은 자주 묻는 질문입니다. Go에서 채널을 닫는 것은 수신자에게 더 이상 데이터가 없음을 알리는 방법입니다. 채널을 닫으면 수신자는 발신자가 모든 전송 작업을 완료했음을 시간 내에 알 수 있습니다. 여러 개의 고루틴으로 채워진 채널에서 카운터를 사용하여 채널에 데이터를 보내는 고루틴의 수를 추적할 수 있습니다. 카운터가 0으로 떨어지면 모든 작업이 완료된 것이므로 안전하게 채널을 닫을 수 있습니다. 채널을 닫은 후 수신자는 수신 표현식의 추가 변수를 사용하여 채널이 닫혔는지 확인할 수 있습니다. 이러한 방식으로 모든 작업이 완료된 후 여러 고루틴으로 채워진 채널이 올바르게 닫히도록 보장하여 리소스 누출 및 교착 상태 문제를 피할 수 있습니다.

질문 내용

"공유 메모리를 통해 통신하지 않고 통신을 통해 메모리를 공유한다"는 Go 방식을 따르고 채널을 사용하여 완료할 작업을 비동기적으로 통신하고 작업 처리 결과를 다시 보내려고 합니다.

단순화를 위해 채널 유형을 실제 구조 대신 int로 변경했습니다. 그리고 긴 처리를 time.Sleep()로 대체했습니다.

모든 작업 결과가 전송된 후 ProducedResults ，以便此代码不会卡在最后一个 for 어떻게 닫나요?

quantityOfTasks:= 100
    quantityOfWorkers:= 60
    remainingTasks := make(chan int)
    producedResults := make(chan int)

    // produce tasks
    go func() {
        for i := 0; i < quantityOfTasks; i++ {
            remainingTasks <- 1
        }
        close(remainingTasks)
    }()

    // produce workers
    for i := 0; i < quantityOfWorkers; i++ {
        go func() {
            for taskSize := range remainingTasks {
                // simulate a long task
                time.Sleep(time.Second * time.Duration(taskSize))
                // return the result of the long task
                producedResults <- taskSize
            }
        }()
    }

    // read the results of the tasks and agregate them
    executedTasks := 0
    for resultOfTheTask := range producedResults { //this loop will never finish because producedResults never gets closed
        // consolidate the results of the tasks
        executedTasks += resultOfTheTask
    }

해결 방법

채널에 쓰는 모든 고루틴이 반환된 후 채널을 닫고 싶습니다. WaitGroup을 사용하면 다음을 달성할 수 있습니다.

으아악

위 내용은 모든 작업이 완료되면 여러 고루틴으로 채워진 채널을 어떻게 닫나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!