Microsoft MVP성태의 닷넷 이야기
VC++: 148. Golang - 채널에 따른 다중 작업 처리 [링크 복사], [링크+제목 복사]
조회: 573
글쓴 사람
정성태 (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으로 작업한 것과 별반 다를 바가 없지만, 뭔가 비동기적으로 발생하는 이벤트를 한 곳에서 확인하는 것이 관리적인 차원에서 더 나을 수 있습니다.




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



donaricano-btn



[최초 등록일: ]
[최종 수정일: 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)
12909정성태1/10/202258오류 유형: 782. Visual Studio 2022 설치 시 "Couldn't install Microsoft.VisualCpp.Redist.14.Latest"
12908정성태1/10/2022123.NET Framework: 1132. C# - ref/out 매개변수의 IL 코드 처리
12907정성태1/9/202275오류 유형: 781. (youtube-dl.exe) 실행 시 "This app can't run on your PC" / "Access is denied." 오류 발생
12906정성태1/9/2022169.NET Framework: 1131. C# - 네임스페이스까지 동일한 타입을 2개의 DLL에서 제공하는 경우 충돌을 우회하는 방법파일 다운로드1
12905정성태1/8/202270오류 유형: 780. Could not load file or assembly 'Microsoft.VisualStudio.TextTemplating.VSHost.15.0, Version=16.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a' or one of its dependencies.
12904정성태1/8/2022147개발 환경 구성: 623. Visual Studio 2022 빌드 환경을 위한 github Actions 설정
12903정성태1/7/202277.NET Framework: 1130. C# - ELEMENT_TYPE_INTERNAL 유형의 사용 예
12902정성태1/7/202252오류 유형: 779. SQL 서버 로그인 에러 - provider: Shared Memory Provider, error: 0 - No process is on the other end of the pipe.
12901정성태1/5/202277오류 유형: 778. C# - .NET 5+에서 warning CA1416: This call site is reachable on all platforms. '...' is only supported on: 'windows' 경고 발생
12900정성태1/5/2022265개발 환경 구성: 622. vcpkg로 ffmpeg를 빌드하는 경우 생성될 구성 요소 제어하는 방법
12899정성태1/3/202286개발 환경 구성: 621. windbg에서 python 스크립트 실행하는 방법 - pykd (2)
12898정성태1/2/2022205.NET Framework: 1129. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 비디오 인코딩 예제(encode_video.c) [1]파일 다운로드1
12897정성태1/2/2022282.NET Framework: 1128. C# - 화면 캡처한 이미지를 ffmpeg(FFmpeg.AutoGen)로 동영상 처리 [4]파일 다운로드1
12896정성태1/1/2022155.NET Framework: 1127. C# - FFmpeg.AutoGen 라이브러리를 이용한 기본 프로젝트 구성파일 다운로드1
12895정성태12/31/2021302.NET Framework: 1126. C# - snagit처럼 화면 캡처를 연속으로 수행해 동영상 제작파일 다운로드1
12894정성태12/30/2021446.NET Framework: 1125. C# - DefaultObjectPool<T>의 IDisposable 개체에 대한 풀링 문제 [3]파일 다운로드1
12893정성태12/27/2021448.NET Framework: 1124. C# - .NET Platform Extension의 ObjectPool<T> 사용법 소개파일 다운로드1
12892정성태12/26/2021381기타: 83. unsigned 형의 이전 값이 최댓값을 넘어 0을 지난 경우, 값의 차이를 계산하는 방법
12891정성태12/23/2021292스크립트: 38. 파이썬 - uwsgi의 --master 옵션
12890정성태12/23/2021304VC++: 152. Golang - (문자가 아닌) 바이트 위치를 반환하는 strings.IndexRune 함수
12889정성태12/22/2021420.NET Framework: 1123. C# - (SharpDX + DXGI) 화면 캡처한 이미지를 빠르게 JPG로 변환하는 방법파일 다운로드1
12888정성태12/21/2021440.NET Framework: 1122. C# - ImageCodecInfo 사용 시 System.Drawing.Image와 System.Drawing.Bitmap에 따른 Save 성능 차이파일 다운로드1
12887정성태12/21/2021347오류 유형: 777. OpenCVSharp4를 사용한 프로그램 실행 시 "The type initializer for 'OpenCvSharp.Internal.NativeMethods' threw an exception." 예외 발생
12886정성태12/20/2021384스크립트: 37. 파이썬 - uwsgi의 --enable-threads 옵션
12885정성태12/20/2021124오류 유형: 776. uwsgi-plugin-python3 환경에서 MySQLdb 사용 환경
12884정성태12/20/2021211개발 환경 구성: 620. Windows 10+에서 WMI root/Microsoft/Windows/WindowsUpdate 네임스페이스 제거
1  [2]  3  4  5  6  7  8  9  10  11  12  13  14  15  ...