Microsoft MVP성태의 닷넷 이야기
.NET Framework: 2012. C# - async/await 그리고 스레드 (3) Task.Delay 재현 [링크 복사], [링크+제목 복사],
조회: 9693
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
(연관된 글이 3개 있습니다.)
(시리즈 글이 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)
13533정성태1/18/20242679닷넷: 2206. C# - TCP KeepAlive의 서버 측 구현파일 다운로드1
13532정성태1/17/20242617닷넷: 2205. C# - SuperSimpleTcp 사용 시 주의할 점파일 다운로드1
13531정성태1/16/20242656닷넷: 2204. C# - TCP KeepAlive에 새로 추가된 Retry 옵션파일 다운로드1
13530정성태1/15/20242386닷넷: 2203. C# - Python과의 AES 암호화 연동파일 다운로드1
13529정성태1/15/20242396닷넷: 2202. C# - PublishAot의 glibc에 대한 정적 링킹하는 방법
13528정성태1/14/20242536Linux: 68. busybox 컨테이너에서 실행 가능한 C++, Go 프로그램 빌드
13527정성태1/14/20242425오류 유형: 892. Visual Studio - Failed to launch debug adapter. Additional information may be available in the output window.
13526정성태1/14/20242484닷넷: 2201. C# - Facebook 연동 / 사용자 탈퇴 처리 방법
13525정성태1/13/20242368오류 유형: 891. Visual Studio - Web Application을 실행하지 못하는 IISExpress
13524정성태1/12/20242451오류 유형: 890. 한국투자증권 KIS Developers OpenAPI - GW라우팅 중 오류가 발생했습니다.
13523정성태1/12/20242220오류 유형: 889. Visual Studio - error : A project with that name is already opened in the solution.
13522정성태1/11/20242448닷넷: 2200. C# - HttpClient.PostAsJsonAsync 호출 시 "Transfer-Encoding: chunked" 대신 "Content-Length" 헤더 처리
13521정성태1/11/20242554닷넷: 2199. C# - 한국투자증권 KIS Developers OpenAPI의 WebSocket Ping, Pong 처리
13520정성태1/10/20242345오류 유형: 888. C# - Unable to resolve service for type 'Microsoft.Extensions.ObjectPool.ObjectPool`....'
13519정성태1/10/20242294닷넷: 2198. C# - Reflection을 이용한 ClientWebSocket의 Ping 호출파일 다운로드1
13518정성태1/9/20242529닷넷: 2197. C# - ClientWebSocket의 Ping, Pong 처리
13517정성태1/8/20242367스크립트: 63. Python - 공개 패키지를 이용한 위성 이미지 생성 (pystac_client, odc.stac)
13516정성태1/7/20242441닷넷: 2196. IIS - AppPool의 "Disable Overlapped Recycle" 옵션의 부작용
13515정성태1/6/20242807닷넷: 2195. async 메서드 내에서 C# 7의 discard 구문 활용 사례 [1]
13514정성태1/5/20242455개발 환경 구성: 702. IIS - AppPool의 "Disable Overlapped Recycle" 옵션
13513정성태1/5/20242413닷넷: 2194. C# - WebActivatorEx / System.Web의 PreApplicationStartMethod 특성
13512정성태1/4/20242386개발 환경 구성: 701. IIS - w3wp.exe 프로세스의 ASP.NET 런타임을 항상 Warmup 모드로 유지하는 preload Enabled 설정
13511정성태1/4/20242368닷넷: 2193. C# - ASP.NET Web Application + OpenAPI(Swashbuckle) 스펙 제공
13510정성태1/3/20242278닷넷: 2192. C# - 특정 실행 파일이 있는지 확인하는 방법 (Linux)
13509정성태1/3/20242383오류 유형: 887. .NET Core 2 이하의 프로젝트에서 System.Runtime.CompilerServices.Unsafe doesn't support netcoreapp2.0.
13508정성태1/3/20242429오류 유형: 886. ORA-28000: the account is locked
1  2  3  4  [5]  6  7  8  9  10  11  12  13  14  15  ...