Microsoft MVP성태의 닷넷 이야기
VC++: 148. Golang - 채널에 따른 다중 작업 처리 [링크 복사], [링크+제목 복사]
조회: 1324
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일

Golang - 채널에 따른 다중 작업 처리

Go 언어로 프로그램을 하다 보면, 자칫 goroutine을 남발해 어느 순간이 되면 프로그램의 실행 경로가 어떻게 되는지 감이 안 오는 경우가 있습니다. 물론, 비동기 처리를 훌륭하게 그려낼 수 있는 뇌구조를 가진 개발자라면 상관없겠지만, 저처럼 ^^ 일반인은 역시 동기 처리가 편할 수밖에 없습니다.

그래서 최대한 실행 경로를 구조적으로 유지하는 것이 중요한데요, 가령 channel에 따른 실행 처리를 할 때 각각의 경우 별로 goroutine을 사용할 수도 있겠지만,

package main

import (
    "bufio"
    "fmt"
    "os"
    "time"
)

func main() {
    go WorkPer1Sec()
    go WorkPer5Sec()

    // 프로세스 종료를 막기 위해.
    bufio.NewReader(os.Stdin).ReadLine()
}

func WorkPer5Sec() {

    // 5초마다 수행할 작업
    for {
        <-time.After(5 * time.Second)
        fmt.Println("5sec elapsed")
    }
}

func WorkPer1Sec() {

    // 1초마다 수행할 작업
    for {
        <-time.After(1 * time.Second)
        fmt.Println("1sec elapsed")
    }
}

select를 이용해 한데 모으는 것도 가능합니다.

func main() {

    go WorkPer()

    bufio.NewReader(os.Stdin).ReadLine()
}

func WorkPer() {

    time5 := time.Tick(5 * time.Second)
    time1 := time.Tick(1 * time.Second)

    for {

        select {
        case <-time5:
            fmt.Print("5, ")
        case <-time1:
            fmt.Print("1, ")
        }
    }
}

/* 출력 결과
1, 1, 1, 1, 5, 1, 1, 1, 1, 1, 5, 1, 1, 1, 1, 1, 5, 1, 1, 1, 1, 1, 
*/

대신 이런 경우에는 채널이 하나의 goroutine 내에서 처리되기 때문에 동일한 CPU 스레드에서 동작한다는 특징이 있습니다. 이로 인해 분리된 채널에서의 공유 변수에 대한 동기화는 필요 없지만 스레드 점유에 따른 간섭은 발생할 수 있습니다. 가령, 다음과 같이 5초 채널에서 (I/O 발생이 아닌) CPU 소비가 필요한 동작을 하게 되면,

func WorkPer() {

    time5 := time.Tick(5 * time.Second)
    time1 := time.Tick(1 * time.Second)

    for {

        select {
        case <-time5:
            fmt.Print("5, ")

            now := time.Now()
            for {
                var elapsed = time.Since(now)
                if elapsed.Seconds() > 5 { // 일부러 5초가 걸리는 CPU 작업을 수행
                    break
                }
            }
        case <-time1:
            fmt.Print("1, ")
        }

    }
}

화면에는 '1' 채널의 작업에 영향을 줘 다음과 같은 식의 예측할 수 없는 출력이 발생합니다.

...[생략]..., 5, 1, 1, 5, 1, 1, 5, 5, 1, 1, 5, 5, 1, 1, 5

만약 저런 상황이라면, 각각의 channel 작업을 분리해 goroutine으로 실행하시면 됩니다.

func WorkPer() {

    time5 := time.Tick(5 * time.Second)
    time1 := time.Tick(1 * time.Second)

    for {

        select {
        case <-time5:
            go Work5()

        case <-time1:
            go Work1()
        }

    }
}

func Work1() {
    fmt.Print("1, ")
}

func Work5() {
    fmt.Print("5, ")

    now := time.Now()
    for {
        var elapsed = time.Since(now)
        if elapsed.Seconds() > 5 {
            break
        }
    }
}

/* 출력 결과
1, 1, 1, 1, 5, 1, 1, 1, 1, 1, 5, 1, 1, 1, 1, 1, 5, 1, 1, 1, 1, 1, 
*/

어찌 보면 처음부터 goroutine으로 작업한 것과 별반 다를 바가 없지만, 뭔가 비동기적으로 발생하는 이벤트를 한 곳에서 확인하는 것이 관리적인 차원에서 더 나을 수 있습니다.




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]







[최초 등록일: ]
[최종 수정일: 9/9/2021]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 




1  2  3  4  5  6  7  8  9  [10]  11  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
12895정성태12/31/20211665.NET Framework: 1126. C# - snagit처럼 화면 캡처를 연속으로 수행해 동영상 제작파일 다운로드1
12894정성태12/30/20211293.NET Framework: 1125. C# - DefaultObjectPool<T>의 IDisposable 개체에 대한 풀링 문제 [3]파일 다운로드1
12893정성태12/27/20211544.NET Framework: 1124. C# - .NET Platform Extension의 ObjectPool<T> 사용법 소개파일 다운로드1
12892정성태12/26/20211118기타: 83. unsigned 형의 이전 값이 최댓값을 넘어 0을 지난 경우, 값의 차이를 계산하는 방법
12891정성태12/23/20211003스크립트: 38. 파이썬 - uwsgi의 --master 옵션
12890정성태12/23/20211093VC++: 152. Golang - (문자가 아닌) 바이트 위치를 반환하는 strings.IndexRune 함수
12889정성태12/22/20211617.NET Framework: 1123. C# - (SharpDX + DXGI) 화면 캡처한 이미지를 빠르게 JPG로 변환하는 방법파일 다운로드1
12888정성태12/21/20211380.NET Framework: 1122. C# - ImageCodecInfo 사용 시 System.Drawing.Image와 System.Drawing.Bitmap에 따른 Save 성능 차이파일 다운로드1
12887정성태12/21/20211534오류 유형: 777. OpenCVSharp4를 사용한 프로그램 실행 시 "The type initializer for 'OpenCvSharp.Internal.NativeMethods' threw an exception." 예외 발생
12886정성태12/20/20211197스크립트: 37. 파이썬 - uwsgi의 --enable-threads 옵션
12885정성태12/20/2021967오류 유형: 776. uwsgi-plugin-python3 환경에서 MySQLdb 사용 환경
12884정성태12/20/2021984개발 환경 구성: 620. Windows 10+에서 WMI root/Microsoft/Windows/WindowsUpdate 네임스페이스 제거
12883정성태12/19/20211286오류 유형: 775. uwsgi-plugin-python3 환경에서 "ModuleNotFoundError: No module named 'django'" 오류 발생
12882정성태12/18/20211017개발 환경 구성: 619. Windows Server에서 WSL을 위한 리눅스 배포본을 설치하는 방법
12881정성태12/17/20211261개발 환경 구성: 618. WSL Ubuntu 20.04에서 파이썬을 위한 uwsgi 설치 방법 (2)
12880정성태12/16/20211047VS.NET IDE: 170. Visual Studio에서 .NET Core/5+ 역어셈블 소스코드 확인하는 방법
12879정성태12/16/20214383오류 유형: 774. Windows Server 2022 + docker desktop 설치 시 WSL 2로 선택한 경우 "Failed to deploy distro docker-desktop to ..." 오류 발생
12878정성태12/15/20211215개발 환경 구성: 617. 윈도우 WSL 환경에서 같은 종류의 리눅스를 다중으로 설치하는 방법
12877정성태12/15/20211007스크립트: 36. 파이썬 - pymysql 기본 예제 코드
12876정성태12/14/20211046개발 환경 구성: 616. Custom Sources를 이용한 Azure Monitor Metric 만들기
12875정성태12/13/20211062스크립트: 35. python - time.sleep(...) 호출 시 hang이 걸리는 듯한 문제
12874정성태12/13/2021873오류 유형: 773. shell script 실행 시 "$'\r': command not found" 오류
12873정성태12/12/20211306오류 유형: 772. 리눅스 - PATH에 등록했는데도 "command not found"가 나온다면?
12872정성태12/12/20211097개발 환경 구성: 615. GoLang과 Python 빌드가 모두 가능한 docker 이미지 만들기
12871정성태12/12/20212037오류 유형: 771. docker: Error response from daemon: OCI runtime create failed
12870정성태12/9/20211000개발 환경 구성: 614. 파이썬 - PyPI 패키지 만들기 (4) package_data 옵션
1  2  3  4  5  6  7  8  9  [10]  11  12  13  14  15  ...