때로는 보고 싶지 않은 것을 치워두고 집중해서 확인해보면 뜻밖의 이득을 얻을 수도 있습니다.

오늘 글은 간단한 설명입니다. 카카도 바둑 강좌를 신청했는데 어떤 강좌를 통해 좀 더 이해가 되는지 알아보고 심도 있는 보충을 하도록 하겠습니다.

1. goroutine

Definition

• 함수 앞에 go만 추가하면 됩니다
• 정의에서 비동기 함수인지 구분할 필요는 없습니다
• 스케줄러가 할 것입니다 전환할 수 있는 지점은 많습니다. 이는 단지 참고 사항일 뿐이며, 전환이 보장되거나 다른 곳에서는 전환되지 않을 것이라는 보장은 없습니다. IO 작업, 채널, 잠금 대기, 함수 호출, Runtime.Gosched() 등 . .
• race를 사용하여 데이터 액세스 충돌 감지

먼저 goroutine 사용 방법을 알아보려면 사례를 읽어보세요

먼저 사례를 살펴보겠습니다

이 사례는 go in go라는 키워드만 사용하는 간단한 동시 실행 코드입니다.

이 코드가 무엇을 출력할지 살펴보겠습니다

위 그림에서 이 코드 줄은 아무것도 출력하지 않고 직접 종료되는 것을 볼 수 있습니다.

직접 종료하는 이유는 코드의 메인 인쇄와 fmt 인쇄가 동시에 실행되기 때문입니다. fmt가 데이터가 오기 전에 긴급하게 인쇄하면 외부 루프가 이미 종료된 후 바로 종료됩니다.

Go 언어로! 주요 기능이 종료된 후 모든 고루틴을 직접 종료한다고 가정하므로 고루틴이 오기 전에 긴급 인쇄 데이터가 반환되는 현상이 발생합니다.

그럼 인쇄된 데이터를 어떻게 볼 수 있는지 궁금하시죠? 사실 아주 간단합니다. 메인 함수가 실행된 후 급하게 종료하지 말고 잠시 기다리시면 됩니다. 케이스를 보세요

이번에는 원하는 결과가 표시됩니다.

이 경우 열린 고루틴 개수가 10개인데 1000개로 바꾸면 어떻게 될까요?

1,000명이 동시에 인쇄하는 것처럼 결과는 여전히 정상적으로 표시됩니다.

그럼 10을 설정하는 것이 1000과 무슨 관련이 있나요?

운영체제에 익숙한 분들은 스레드 10개 열어도 문제 없고, 스레드 100개 열어도 큰 문제는 없다는 걸 아실텐데 거의 충분합니다.

일반적으로 시스템에서는 수십 개의 스레드를 열면 충분하지만, 1,000명이 동시에 한 가지 작업을 수행해야 한다면 스레드를 사용하여 문제를 해결할 수 없으며 비동기식 방법이 필요합니다.

하지만 Go 언어에서는! go 키워드를 직접 사용하면 동시에 실행할 수 있습니다.

다음으로 go가 동시에 1000명을 인쇄할 수 있는 이유에 대해 이야기해 보겠습니다.

이란 무엇입니까? 먼저 코루틴과 스레드의 차이점을 살펴보겠습니다.

코루틴은 경량 스레드, 비선점형 멀티태스킹, 코루틴이 적극적으로 제어권을 넘겨줍니다. 轻量级的线程，非抢占式多任务处理，由协程主动交出控制权。

线程大家应该都知道是可以被操作系统在任何时候进行切换，所以说线程就是抢占式多任务处理，线程是没有控制权，哪怕是一个语句执行到一半都会被操作系统切掉，然后转到其它线程去操作。

那么反之对于协程来说，什么时候交出控制权，什么时候不交出控制权是由协程内部主动决定的，正是因为这种非抢占式，所以被称之为轻量级。

并且多个协程是可以在一个或多个线程上运行的

첫 번째 섹션에서 우리는 Go에서 많은 고루틴을 열 수 있다는 것을 배웠고, 고루틴 사이의 양방향 채널은 채널

기본 사용법

위 사례에서 볼 수 있듯이 make 기능을 사용하여 직접 채널을 생성할 수 있습니다.

7번째와 8번째 라인은 채널에 데이터를 보내는 라인입니다.

그럼 이 사건은 실행될 수 있을까요? 와서 시험해 보세요

이때 오류가 보고된 것을 볼 수 있습니다. 해당 오류는 채널에 1을 보낼 때 교착 상태가 발생한다는 의미입니다.

그런 다음 이전 사진으로 돌아갑니다.

위에서 말했듯이 채널은 고루틴과 고루틴 간의 상호 작용입니다.

하지만 이 경우에는 고루틴이 하나뿐이므로 이를 수신하려면 또 다른 고루틴이 필요합니다.

이제 고루틴을 시작하는 방법을 알아야 합니다.

위 그림에서는 또 다른 고루틴을 새로 오픈한 후, 무한 루프를 이용해 채널에서 보낸 값을 받아 출력해봤습니다.

하지만 채널에 두 개의 데이터를 보냈는데, 현재 인쇄 결과에는 한 개의 데이터만 있는 것을 볼 수 있습니다. 하지만 우리가 시작한 것보다 낫습니다. 그렇죠!

그러면 왜 이런 일이 일어나는 걸까요?

코드의 실행 흐름을 이해할 수 있습니다. 먼저 1이 채널로 전송된 다음 루프에서 첫 번째 값을 얻어 인쇄됩니다.

데이터 2를 채널에 다시 보내지만 인쇄하기 직전에 종료하여 데이터 1만 표시되고 데이터 2는 표시되지 않는 현상이 발생합니다.

Kaka의 설명을 통해 이 문제를 해결하는 방법을 이미 알고 계실 것입니다.

channelDome 함수에 지연된 종료 시간을 추가하는 것입니다.

채널을 매개변수로 전달

위에서 볼 수 있듯이 go 뒤에는 클로저 함수가 오고 이 클로저에 사용된 c는 c에서 사용된 외부 레이어입니다.

그렇다면 매개변수를 사용하여 이 c를 전달하는 것이 가능한가요? 대답은 '예'입니다.

물론 다른 매개변수도 전달할 수 있습니다

위 그림을 보면 채널뿐만 아니라 id 매개변수도 전달됨과 동시에 코드를 포함된 부분에 직접 최적화할 수도 있습니다. 즉, 값은 다음과 같습니다. 채널에서 직접 가져왔습니다.

다중 채널 만들기

위 그림에서 볼 수 있듯이 모두가 자신의 채널을 갖고 배포한 후 각자가 받은 가치를 받아 인쇄하게 됩니다. 밖으로.

마찬가지로 채널에 데이터를 보내기 위해 26번째 줄에 새로운 for 루프를 추가한 것을 볼 수 있습니다.

실행 결과를 보면, receive i와 receive I 두 값이 나오는 등 인쇄 순서가 헷갈리는 것을 알 수 있습니다.

이때, 저희가 채널에 데이터를 보내면 순서대로 보내주는게 좀 의심되시죠? 그러면 수신 시 순서대로 수신되어야 합니다.

데이터가 순서대로 전송된다고 확신하므로 문제는 Printf에서만 발생할 수 있습니다.

Printf는 IO가 있고 고루틴으로 스케줄링되어 있기 때문에 이때 Printf는 고장나지만 수신된 값이 하나씩 출력됩니다.

채널을 반환 값으로 사용

이전 섹션의 사례는 모두 채널별로 생성된 다음 매개 변수로 전달되었습니다.

이 섹션에서는 채널을 반환 값으로 반환합니다.

소스 코드

package mainimport (
	"fmt"
	"time")func createWorker(id int) chan int {
	c := make(chan int)
	go func() {
		for {
			fmt.Printf("Worker %d receive %c\n", id, 

여기서 보면 작업자 함수를 createWorker 함수로 변경한 것을 볼 수 있습니다. 이 함수에서는 채널이 직접 생성되기 때문입니다.

그런 다음 채널에서 받은 값이 코루틴을 통해 인쇄됩니다.

채널을 복귀합니다.

실행 결과를 살펴보겠습니다

실행 결과를 보면 우리의 코드 작성이 여전히 올바른 것을 알 수 있지만, 이때 반환된 채널을 매우 직관적으로 사용하는 방법을 알 수 있습니다

하지만 코드가 많으면 알 수 없습니다. 이 채널을 사용하는 방법 이 모든 코드를 사용하면 간단히 수정하면 됩니다.

그럼 해야 할 일은 외부 사람들에게 사용법을 알려주는 것입니다. ㅋㅋㅋ

package mainimport (
	"fmt"
	"time")func createWorker(id int) chan

배움에 대한 끈기, 쓰기에 대한 끈기, 공유에 대한 끈기 등은 카카가 창립 이래 늘 지켜온 신념입니다. 거대 인터넷에 올라온 카카의 글이 조금이나마 도움이 되었으면 좋겠습니다. 저는 카카입니다. 다음에 만나요.