Microsoft MVP성태의 닷넷 이야기
.NET Framework: 719. Task를 포함하는 async 메서드의 동작 방식 [링크 복사], [링크+제목 복사]
조회: 3045
글쓴 사람
홈페이지
첨부 파일
 

Task를 포함하는 async 메서드의 동작 방식

이전 글에 이어서,

Task를 포함하지 않는 async 메서드의 동작 방식
; https://www.sysnet.pe.kr/2/0/11415

이번에는 예제 코드를 Task가 있는 것으로 넣어 흐름을 살펴보겠습니다. 이를 위해 예제 코드는 다음의 글에서 작성했던 것으로 재활용합니다.

C# 컴파일러 대신 직접 구현하는 비동기(async/await) 코드
; https://www.sysnet.pe.kr/2/0/11351

using System;
using System.Threading.Tasks;

namespace ConsoleApp1
{
    class Program
    {
        // C# 7.1 async Main
        static async Task Main(string[] args)
        {
            Program pg = new Program();

            await pg.CallAsync();
        }

        private async Task CallAsync()
        {
            string title = DateTime.Now.ToString();
            string text = await GetFileContents();
            Console.WriteLine(title + ": " + text);
        }

        private async Task<string> GetFileContents()
        {
            return await new TaskFactory().StartNew(() => { Thread.Sleep(5000); return "test"; });
        }
    }
}

위의 코드에서 GetFileContents는 async 예약어로 인해 다음과 같은 식으로 코드 구성을 합니다.

private Task GetFileContents()
{
    GetFileContents_StateMachine stateMachine = new GetFileContents_StateMachine
    {
        _this = this,
        _builder = AsyncTaskMethodBuilder<string>.Create(),
        _state = -1,
    };

    stateMachine._builder.Start(ref stateMachine);
    return stateMachine._builder.Task as Task<string>;
}

그리고 stateMachine._builder.Start 호출로 인해 상태 머신의 MoveNext에서 실행되는 첫 코드는 다음과 같습니다.

this._getStringTask = new TaskFactory().StartNew(() => { Thread.Sleep(5000); return "test"; });
awaiter = this._getStringTask.GetAwaiter();
if (awaiter.IsCompleted == false)
{
    this._state = num = 0;
    this._awaiter = awaiter;
    GetFileContents_StateMachine stateMachine = this;
    this._builder.AwaitUnsafeOnCompleted(ref awaiter, ref stateMachine);
    return;
}

사실 이번 글을 쓰기 전까지는, 저 위의 this._getStringTask가 GetFileContents의 마지막에 반환하는 stateMachine._builder.Task일 거라고 생각했었습니다. 그런데, 실제로 해보면 저 2개의 Task는 같지 않습니다.

다시 말해, stateMachine._builder.Task는 GetFileContents 메서드가 async로 바뀌는 바람에 내부에 생성되었던 상태 머신의 AsyncTaskMethodBuilder<string>.Create()로 생성되었던 Task인 반면, this._getStringTask는 그냥 await 예약어의 대상이 되는 메서드가 반환한 Task를 그대로 유지합니다.

동일한 규칙이 GetFileContents를 호출하는 CallAsync에도 적용됩니다. CallAsync는 다음과 같이 상태 머신을 생성하는 코드로 바뀌고,

private Task CallAsync()
{
    CallAsync_StateMachine stateMachine = new CallAsync_StateMachine
    {
        _this = this,
        _builder = AsyncTaskMethodBuilder.Create(),
        _state = -1,
    };

    stateMachine._builder.Start(ref stateMachine);
    return stateMachine._builder.Task;
}

CallAsync 상태 머신의 첫 번째 MoveNext 실행 코드는,

awaiter = _this.GetFileContents().GetAwaiter();
if (awaiter.IsCompleted == false)
{
    this._state = num = 0;
    this._awaiter = awaiter;
    CallAsync_StateMachine stateMachine = this;
    this._builder.AwaitUnsafeOnCompleted(ref awaiter, ref stateMachine);
    return;
}

GetFileContents() 내에서 TaskFactory().StartNew()로 생성되었던 Task가 아닌, GetFileContents 스스로 생성한 Task 객체의 Awaiter를 받아 비동기를 연결합니다.

정리해 보면, 다음과 같은 식으로 Task 객체가 연결됩니다.

GetFileContents
    task = TaskFactory().StartNew() 코드 실행
    task가 동작이 끝나면 실행될 MoveNext 코드를 등록
    
    하지만 스스로 상태 머신에서 AsyncTaskMethodBuilder<string>.Create()로 생성한 Task를 반환

CallAsync
    GetFileContents가 스스로 생성한 Task를 구하고,
    그 Task의 동작이 끝나면 실행될 MoveNext 코드를 등록    

    하지만 스스로 상태 머신에서 AsyncTaskMethodBuilder.Create()로 생성한 Task를 반환

즉, 스레드를 소유한 Task가 호출 스택을 타고 전달되는 것이 아니라, 각각의 async 메서드마다 스스로 생성한 Task 객체를 상위에 전달하고 있었던 것인데... 보면서 어떻게 이것이 비동기 동작을 하는지 이해가 안 되었습니다.




물론 결과적으로 어쨌든 연결된다는 사실이 중요한데 세부적인 것을 알아보면 대충 이렇습니다.

async 메서드는 그것이 호출한 async 메서드로부터 구한 awaiter의 작업이 끝나지 않은 경우 다음 번 작업을 다음과 같이 등록합니다.

awaiter = this.YourAsyncMethod().GetAwaiter();
if (awaiter.IsCompleted == false)
{
    this._state = num = 0;
    this._awaiter = awaiter;
    GetFileContents_StateMachine stateMachine = this;
    this._builder.AwaitUnsafeOnCompleted(ref awaiter, ref stateMachine);
    return;
}

AwaitUnsafeOnCompleted는 호출한 async 메서드로부터 반환받은 awaiter와 현재 async 메서드의 상태 머신 객체를 인자로 받습니다. 이를 이용해,

[SecuritySafeCritical, __DynamicallyInvokable]
public void AwaitUnsafeOnCompleted<TAwaiter, TStateMachine>(ref TAwaiter awaiter, ref TStateMachine stateMachine) where TAwaiter: ICriticalNotifyCompletion where TStateMachine: IAsyncStateMachine
{
    try
    {
        AsyncMethodBuilderCore.MoveNextRunner runnerToInitialize = null;
        Action completionAction = this.m_coreState.GetCompletionAction(AsyncCausalityTracer.LoggingOn ? this.Task : null, ref runnerToInitialize);
        if (this.m_coreState.m_stateMachine == null)
        {
            Task<TResult> builtTask = this.Task;
            this.m_coreState.PostBoxInitialization((TStateMachine) stateMachine, runnerToInitialize, builtTask);
        }
        awaiter.UnsafeOnCompleted(completionAction);
    }
    catch (Exception exception)
    {
        AsyncMethodBuilderCore.ThrowAsync(exception, null);
    }
}

AsyncTaskMethodBuilder의 (struct로 함께 생성되었던) m_coreState 객체가 소유한 델리게이트에 StateMachine의 MoveNext 작업을 담은 후 이것을 awaiter의 Task에 연결합니다.

// System.Runtime.CompilerServices.TaskAwaiter

[SecurityCritical, __DynamicallyInvokable]
public void UnsafeOnCompleted(Action continuation)
{
    OnCompletedInternal(this.m_task, continuation, true, false);
}

[MethodImpl(MethodImplOptions.NoInlining), SecurityCritical]
internal static void OnCompletedInternal(Task task, Action continuation, bool continueOnCapturedContext, bool flowExecutionContext)
{
    if (continuation == null)
    {
        throw new ArgumentNullException("continuation");
    }
    StackCrawlMark lookForMyCaller = StackCrawlMark.LookForMyCaller;
    if (TplEtwProvider.Log.IsEnabled() || Task.s_asyncDebuggingEnabled)
    {
        continuation = OutputWaitEtwEvents(task, continuation);
    }
    task.SetContinuationForAwait(continuation, continueOnCapturedContext, flowExecutionContext, ref lookForMyCaller);
}

그리고 Task에 등록된 델리게이트의 수행은 상태 머신의 MoveNext에서 마지막 SetResult(또는 SetException)을 수행할 때 실행됩니다.




정리해 보면, 전체적으로는 다음과 같은 내부적인 비동기 처리가 연쇄적으로 발생합니다.

[async/await 코드 실행 시]

GetFileContents
    Task task = TaskFactory().StartNew 수행
    if (task 수행 완료)
    {
        GetFileContents의 두 번째 MoveNext가 실행될 때의 코드를 동기로 실행
        GetFileContents.Task 역시 수행 완료로 표시
    }
    else
    {
        task에 GetFileContents의 MoveNext를 등록
    }
    GetFileContents.Task 반환

CallAsync
    Task task = GetFileContents가 생성한 Task
    if (task 수행 완료)
    {
        CallAsync의 두 번째 MoveNext가 실행될 때의 코드를 동기로 실행
        CallAsync.Task 역시 수행 완료로 표시
    }
    else
    {
        task에 CallAsync의 MoveNext를 등록
    }
    CallAsync.Task 반환

[StartNew 수행이 완료된 후]
    StartNew Task의 스레드에서 GetFileContents가 등록한 MoveNext를 수행
        GetFileContents.MoveNext 내에서 SetResult 수행
            SetResult 내에서 GetFileContents.Task에 CallAsync가 등록한 MoveNext를 수행
                CallAsync.MoveNext 내에서 SetResult 수행
                    ...[반복]...




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

[연관 글]





[최초 등록일: ]
[최종 수정일: 12/22/2017 ]

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

비밀번호

댓글 쓴 사람
 




... 16  17  18  19  20  21  22  23  24  25  [26]  27  28  29  30  ...
NoWriterDateCnt.TitleFile(s)
11441정성태1/18/20182553오류 유형: 447. ASP.NET Core 배포 오류 - Ensure that restore has run and that you have included '...' in the TargetFrameworks for your project.
11440정성태1/17/20182925.NET Framework: 727. ASP.NET의 HttpContext.Current 구현에 대응하는 ASP.NET Core의 IHttpContextAccessor/HttpContextAccessor 사용법파일 다운로드1
11439정성태8/25/20186165기타: 69. C# - CPU 100% 부하 주는 프로그램파일 다운로드1
11438정성태1/17/20183318오류 유형: 446. Error CS0234 The type or namespace name 'ITuple' does not exist in the namespace
11437정성태1/17/20182967VS.NET IDE: 124. Platform Toolset 설정에 따른 Visual C++의 헤더 파일 기본 디렉터리
11436정성태1/16/20183089개발 환경 구성: 352. ASP.NET Core (EXE) 프로세스가 IIS에서 호스팅되는 방법 - ASP.NET Core Module(AspNetCoreModule) [1]
11435정성태1/16/20183847개발 환경 구성: 351. OWIN 웹 서버(EXE)를 IIS에서 호스팅하는 방법 - HttpPlatformHandler (Reverse Proxy)파일 다운로드2
11434정성태1/15/20183892개발 환경 구성: 350. 사용자 정의 웹 서버(EXE)를 IIS에서 호스팅하는 방법 - HttpPlatformHandler (Reverse Proxy)파일 다운로드2
11433정성태1/15/20183277개발 환경 구성: 349. dotnet ef 명령어 사용을 위한 준비
11432정성태1/11/20184430.NET Framework: 726. WPF + Direct2D + SharpDX 출력 C# 예제파일 다운로드2
11431정성태1/11/20183808.NET Framework: 725. C# - 동기 방식이면서 비동기 메서드처럼 구현한 사례
11430정성태1/10/20185600.NET Framework: 724. WPF + Direct2D 출력 C# 예제 [1]파일 다운로드1
11429정성태1/9/20182462개발 환경 구성: 348. ASP.NET Core 2.1 Preview 버전 적용 방법
11428정성태1/7/20183386개발 환경 구성: 347. WinForm 프로젝트를 WPF 프로젝트 유형으로 변경하는 방법파일 다운로드1
11427정성태1/5/20182968오류 유형: 445. vcpkg 빌드 오류 - Starting the CLR failed with HRESULT 80040153
11426정성태10/19/20184191오류 유형: 444. curl로 호출할 때 발생하는 오류 정리
11425정성태1/4/20182472개발 환경 구성: 346. ASP.NET Core Web Application을 IIS에서 호스팅하는 방법 (2)
11424정성태1/4/20182800개발 환경 구성: 345. ASP.NET Core 프로젝트를 명령행에서 빌드하는 방법
11423정성태1/4/20189982VC++: 123. 내가 만든 코드보다 OpenCV의 속도가 월등히 빠른 이유 [4]파일 다운로드2
11422정성태1/3/20185578.NET Framework: 723. C# - OpenCvSharp 사용 시 C/C++을 이용한 속도 향상 (for 루프 연산) [4]파일 다운로드1
11421정성태1/2/20182407오류 유형: 443. Visual Studio - nuget configuration is invalid
11420정성태12/30/20173848.NET Framework: 722. C# - Windows 10 운영체제의 데스크톱 앱에서 음성인식(SpeechRecognizer) 사용하는 방법 [2]파일 다운로드1
11419정성태12/23/20174304.NET Framework: 721. WebClient 타입의 ...Async 메서드 호출은 왜 await + 동기 호출 시 hang 현상이 발생할까요? [2]파일 다운로드1
11418정성태1/10/20185214.NET Framework: 720. 비동기 메서드 내에서 await 시 ConfigureAwait 호출 의미파일 다운로드1
11417정성태12/22/20173045.NET Framework: 719. Task를 포함하는 async 메서드의 동작 방식
11416정성태12/21/20172932.NET Framework: 718. AsyncTaskMethodBuilder.Create() 메서드 동작 방식
... 16  17  18  19  20  21  22  23  24  25  [26]  27  28  29  30  ...