고루틴을 사용하여 값을 처리하고 결과를 슬라이스로 수집할 때 교착 상태를 방지하는 방법은 무엇입니까?

고루틴을 사용하여 효율적으로 값을 처리하고 결과를 슬라이스로 수집

고루틴의 활용은 Go 프로그래밍에서 혁신적인 요소가 될 수 있습니다. 동시 작업 실행 및 효율적인 처리. 그러나 잠재적인 함정을 피하려면 적절한 구현이 중요합니다.

문제:

코드베이스에서 고루틴을 사용하려고 하면 "치명적인 오류: 모든 고루틴이 잠자기 상태입니다. 이중 자물쇠!" 발생합니다. 목표는 목록의 값을 동시에 처리한 후 처리된 결과를 새 목록에 누적하는 것입니다. 그러나 축적 단계에서는 어려움이 나타납니다.

코드 분해:

제공된 코드 조각에는 몇 가지 필수 요소가 포함되어 있습니다.

// Process each item with a goroutine and send output to sampleChan
go newSample(line, *replicatePtr, *timePtr, sampleChan, &wg)

• 이 고루틴은 데이터를 동시에 처리하고 결과를 SampleChan이라는 채널로 보냅니다.

// Read from sampleChan and put into a slice
for s := range sampleChan {
    sampleList = append(sampleList, s)
}
close(sampleChan)

• 코드는 채널에서 결과를 수집하여 슬라이스에 통합하려고 시도합니다.

해결책:

오류는 두 가지 문제, 즉 작업자 완료를 너무 일찍 기다리는 것과 부적절한 채널 폐쇄 타이밍으로 인해 발생합니다. 다음 수정 사항은 이러한 문제를 해결합니다.

go func() {
    wg.Wait()
    close(sampleChan)
}()

• 별도의 고루틴을 시작하여 작업자가 완료될 때까지 채널 폐쇄를 연기합니다.

또한 스타일적 응집력을 위해 구조 조정을 고려합니다. newSample을 결과 생성을 위한 동기 함수로 사용하여 다음 코드를 생성합니다.

for i, line := range contents {
    wg.Add(1)
    go func(line string) {
        defer wg.Done()
        sampleChan <- newSample(line, *replicatePtr, *timePtr)
    }(line)
}

이 수정된 접근 방식은 코드 가독성을 향상시키고 테스트를 용이하게 하며 동시성 관리를 단순화하여 wg.Done( ).

위 내용은 고루틴을 사용하여 값을 처리하고 결과를 슬라이스로 수집할 때 교착 상태를 방지하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!