Microsoft MVP성태의 닷넷 이야기
.NET Framework: 2012. C# - async/await 그리고 스레드 (3) Task.Delay 재현 [링크 복사], [링크+제목 복사],
조회: 18749
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
(연관된 글이 4개 있습니다.)
(시리즈 글이 4개 있습니다.)
.NET Framework: 2008. C# - async/await 그리고 스레드 (1) MyTask로 재현
; https://www.sysnet.pe.kr/2/0/13055

.NET Framework: 2009. C# - async/await 그리고 스레드 (2) MyTask의 호출 흐름
; https://www.sysnet.pe.kr/2/0/13056

.NET Framework: 2012. C# - async/await 그리고 스레드 (3) Task.Delay 재현
; https://www.sysnet.pe.kr/2/0/13060

.NET Framework: 2014. C# - async/await 그리고 스레드 (4) 비동기 I/O 재현
; https://www.sysnet.pe.kr/2/0/13062




C# - async/await 그리고 스레드 (3) Task.Delay 재현

지난 글(1, 2)을 통해, 기본적인 비동기 호출에 대한 동작 방식을 우리가 직접 MyTask를 구현하면서 알아봤습니다.

자, 그럼 이해를 돕기 위해 또 하나의 실습을 해볼까요? 적당한 걸로, 기존의 Task.Delay와 같은 기능을 구현해 보겠습니다. Task.Delay는 Thread.Sleepawaitable 버전인데요, 다음과 같은 식으로 사용합니다.

using System;

internal class Program
{
    static async Task Main(string[] args)
    {
        Console.WriteLine($"[{DateTime.Now}] 1단계: threadid == {Thread.CurrentThread.ManagedThreadId}");
        await Task.Delay(2000); // 2초의 비동기 sleep 후, 아래의 코드 실행
        Console.WriteLine($"[{DateTime.Now}] 2단계: threadid == {Thread.CurrentThread.ManagedThreadId}");
    }
}

/* 출력 결과
[2022-05-11 오후 10:12:12] 1단계: threadid == 1
[2022-05-11 오후 10:12:14] 2단계: threadid == 4
*/




그런데, Sleep은 Win32 API로 제공은 되지만 엄밀히 비동기 버전의 SleepAsync API는 없습니다. 그렇다면 Task.Delay는 도대체 어떻게 구현을 한 것이고, await 이후의 코드는 어떤 스레드에서 실행이 되는 것일까요?

이를 알아보기 위해 우리가 만든 MyTask에도 Delay 기능을 넣어보겠습니다. 여기서 구현의 핵심은, (누누이 말했지만) await 이후로 분리된 코드를 실행할 스레드가 있어야 (혹은 없다면 동기 호출) 한다는 점입니다.

자, 그럼 간단하게는 (기존 소스 코드에서) 이런 식으로 부가 코드를 넣어 구현하는 것이 가능합니다.

internal class Program
{
    static async Task Main(string[] args)
    {
        Console.WriteLine($"1단계: threadid == {Thread.CurrentThread.ManagedThreadId}");
        await MyTask.Delay(1000);
        Console.WriteLine($"2단계: threadid == {Thread.CurrentThread.ManagedThreadId}");
    }
}

public class MyTask
{
    // ...[생략]...

    public static MyTask Delay(int milliSeconds)
    {
        Action action = () =>
        {
            Thread.Sleep(milliSeconds);
        };

        return new MyTask(action);
    }
}

/* 출력 결과
[2022-05-11 오후 10:14:24] 1단계: threadid == 1
[2022-05-11 오후 10:14:26] 2단계: threadid == 9
*/

비록, 구현은 했지만 한 가지 아쉬운 점이 있습니다. 바로 Sleep 시간 동안 (MyTask 내에서 새로 생성하는) 스레드 하나가 점유된다는 것입니다. Sleep이 비동기 I/O 호출을 지원하지도 않으므로 얼핏 보면 저게 최선일 듯한데요, 다행히 방법이 있습니다. 바로 System.Threading.Timer를 이용해 스레드 점유를 없애고 CLR ThreadPool을 활용하는 것입니다.

실제로 이 방법은 Task.Delay가 이용하고 있는데요, 우리도 다음과 같이 구현할 수 있습니다.

internal class Program
{
    static async Task Main(string[] args)
    {
        Console.WriteLine($"[{DateTime.Now}] 1단계: threadid == {Thread.CurrentThread.ManagedThreadId}");
        await MyTask.DelayAsync(2000);
        Console.WriteLine($"[{DateTime.Now}] 2단계: threadid == {Thread.CurrentThread.ManagedThreadId}");
    }
}

public class DelayTask : MyTask
{
    System.Threading.Timer _timer;

    public DelayTask(int milliSeconds)
    {
        _timer = new Timer(expiredCallback, null, milliSeconds, 0);
    }

    private void expiredCallback(object? state)
    {
        _timer.Dispose();
        this.SetComplete();
    }
}

public class MyTask
{
    // ...[생략]...

    public MyTask() { }

    // ...[생략]...

    public static DelayTask DelayAsync(int milliSeconds)
    {
        return new DelayTask(milliSeconds);
    }

    // ...[생략]...
}

/* 실행 결과 */
[2022-05-11 오후 10:14:39] 1단계: threadid == 1
[2022-05-11 오후 10:14:41] 2단계: threadid == 4

간단하죠? ^^ 스레드 걱정을 할 필요가 없는 이유는, Timer 타입의 생성자에 전달하는 callback 메서드를 (지정된 시간 이후에) CLR ThreadPool로부터 선택된 스레드가 실행해 주기 때문입니다. 그리고, 자연스럽게 그 과정에서 MyTask.SetComplete의 호출로 인해 await 이후의 "분할 2" 코드까지 실행이 됩니다.

(첨부 파일은 이 글의 예제 코드를 포함합니다.)




자, 이렇게 해서 (다음 편에서 다룰) 비동기 I/O를 제외하고는 기존의 Task에서 제공하던 Delay나 Task.Run을 이용한 비동기 호출 방식을 다뤄봤습니다. 보는 바와 같이, 마법은 없습니다. 단지 C# 컴파일러가 분리한 await 이후의 코드를 1) 사용자가 제공하든, 2) CLR ThreadPool에서 제공하든, 3) 설령 그것이 동기 또는 비동기이든 특정 스레드로 하여금 실행하도록 만들어야 한다는 사실에는 변함이 없습니다.




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

[연관 글]






[최초 등록일: ]
[최종 수정일: 3/1/2024]

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)
13793정성태10/28/20245134C/C++: 183. C++ - 윈도우에서 한글(및 유니코드)을 포함한 콘솔 프로그램을 컴파일 및 실행하는 방법
13792정성태10/27/20244620Linux: 99. Linux - 프로세스의 실행 파일 경로 확인
13791정성태10/27/20244885Windows: 267. Win32 API의 A(ANSI) 버전은 DBCS를 사용할까요?파일 다운로드1
13790정성태10/27/20244607Linux: 98. Ubuntu 22.04 - 리눅스 커널 빌드 및 업그레이드
13789정성태10/27/20244908Linux: 97. menuconfig에 CONFIG_DEBUG_INFO_BTF, CONFIG_DEBUG_INFO_BTF_MODULES 옵션이 없는 경우
13788정성태10/26/20244443Linux: 96. eBPF (bpf2go) - fentry, fexit를 이용한 트레이스
13787정성태10/26/20244949개발 환경 구성: 730. github - Linux 커널 repo를 윈도우 환경에서 git clone하는 방법 [1]
13786정성태10/26/20245203Windows: 266. Windows - 대소문자 구분이 가능한 파일 시스템
13785정성태10/23/20244969C/C++: 182. 윈도우가 운영하는 2개의 Code Page파일 다운로드1
13784정성태10/23/20245235Linux: 95. eBPF - kprobe를 이용한 트레이스
13783정성태10/23/20244845Linux: 94. eBPF - vmlinux.h 헤더 포함하는 방법 (bpf2go에서 사용)
13782정성태10/23/20244605Linux: 93. Ubuntu 22.04 - 커널 이미지로부터 커널 함수 역어셈블
13781정성태10/22/20244785오류 유형: 930. WSL + eBPF: modprobe: FATAL: Module kheaders not found in directory
13780정성태10/22/20245546Linux: 92. WSL 2 - 커널 이미지로부터 커널 함수 역어셈블
13779정성태10/22/20244840개발 환경 구성: 729. WSL 2 - Mariner VM 커널 이미지 업데이트 방법
13778정성태10/21/20245653C/C++: 181. C/C++ - 소스코드 파일의 인코딩, 바이너리 모듈 상태의 인코딩
13777정성태10/20/20244937Windows: 265. Win32 API의 W(유니코드) 버전은 UCS-2일까요? UTF-16 인코딩일까요?
13776정성태10/19/20245250C/C++: 180. C++ - 고수준 FILE I/O 함수에서의 Unicode stream 모드(_O_WTEXT, _O_U16TEXT, _O_U8TEXT)파일 다운로드1
13775정성태10/19/20245477개발 환경 구성: 728. 윈도우 환경의 개발자를 위한 UTF-8 환경 설정
13774정성태10/18/20245182Linux: 91. Container 환경에서 출력하는 eBPF bpf_get_current_pid_tgid의 pid가 존재하지 않는 이유
13773정성태10/18/20244871Linux: 90. pid 네임스페이스 구성으로 본 WSL 2 + docker-desktop
13772정성태10/17/20245144Linux: 89. pid 네임스페이스 구성으로 본 WSL 2 배포본의 계층 관계
13771정성태10/17/20245049Linux: 88. WSL 2 리눅스 배포본 내에서의 pid 네임스페이스 구성
13770정성태10/17/20245327Linux: 87. ps + grep 조합에서 grep 명령어를 사용한 프로세스를 출력에서 제거하는 방법
13769정성태10/15/20246101Linux: 86. Golang + bpf2go를 사용한 eBPF 기본 예제파일 다운로드1
13768정성태10/15/20245379C/C++: 179. C++ - _O_WTEXT, _O_U16TEXT, _O_U8TEXT의 Unicode stream 모드파일 다운로드2
1  2  3  4  5  [6]  7  8  9  10  11  12  13  14  15  ...