계속하기 전에 Go에게 모든 고루틴을 실행하도록 요청하세요.

동시 프로그래밍을 할 때, 실행을 계속하기 전에 모든 고루틴이 완료될 때까지 기다려야 하는 상황에 자주 직면합니다. Go 언어에서는 WaitGroup을 사용하여 이 목표를 달성할 수 있습니다. WaitGroup은 고루틴 그룹이 완료될 때까지 기다리는 데 사용할 수 있는 계산 세마포입니다. 계속하기 전에 WaitGroup의 Wait 메서드를 호출하여 모든 고루틴이 작업을 완료했는지 확인해야 합니다. 이번 글에서는 고루틴의 실행 순서를 관리하기 위해 WaitGroup을 올바르게 사용하는 방법을 소개하겠습니다.

질문 내용

계속하기 전에 모든 고루틴을 실행하려면 golang 스케줄러가 필요합니다. Runtime.gosched()로는 해결할 수 없습니다.

문제는 go 루틴이 너무 빨리 실행되어 start()의 "select"가 stopstream() 내부의 "select" 다음에 실행된 다음 "case <-chanstopstream:" 수신자가 발신자 "case에 대해 준비되지 않았다는 것입니다. retchan <-true:". 이런 일이 발생하면 결과는 stopstream()이 중단될 때와 동일한 동작으로 나타납니다

이 코드를 실행하세요 https://go.dev/play/p/dq85xqju2q_z 여러 번 이 두 가지 응답을 보게 될 것입니다. 일시 중단되지 않은 경우 예상 응답:

으아아아

일시 중지 시 예상되는 응답은 있지만 일시 중지 시에는 그렇게 빠르지 않습니다.

으아아아

코드

2009/11/10 23:00:00 start
2009/11/10 23:00:00 receive chan
2009/11/10 23:00:03 end

해결 방법

현재 고루틴을 계속 실행하기 전에 다른 모든 고루틴을 실행할 수 있는 방법은 없습니다.

고루틴이 차단되지 않도록 문제를 해결했습니다. stopstream:

옵션 1: chanstopstream을 버퍼 채널 chanstopstream 更改为缓冲通道。这确保了 stopstream으로 변경하세요. 이렇게 하면

가 차단 없이 값을 보낼 수 있습니다.

으아아아 https://www.php.cn/link/56e48d306028f2a6c2ebf677f7e8f800

옵션 2

: 값을 보내는 대신 채널을 닫습니다. 발신자는 항상 채널을 닫을 수 있습니다. 채널 값 유형을 반환하는 닫힌 채널에서 0 값을 받습니다.

으아아아 https://www.php.cn/link/a1aa0c486fb1a7ddd47003884e1fc67f

🎜

위 내용은 계속하기 전에 Go에게 모든 고루틴을 실행하도록 요청하세요.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!