Microsoft MVP성태의 닷넷 이야기
.NET Framework: 989. HttpContextAccessor를 통해 이해하는 AsyncLocal<T> [링크 복사], [링크+제목 복사]
조회: 1054
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일

HttpContextAccessor를 통해 이해하는 AsyncLocal<T>

HttpContext.Current가 동기 모델에 적합했다면,

HttpContext.Current를 통해 이해하는 CallContext와 ExecutionContext
; https://www.sysnet.pe.kr/2/0/1608

ASP.NET Core의 HttpContextAccessor는 비동기 모델을 위해 새롭게 나온 타입입니다.

ASP.NET의 HttpContext.Current 구현에 대응하는 ASP.NET Core의 IHttpContextAccessor/HttpContextAccessor 사용법
; https://www.sysnet.pe.kr/2/0/11440

그리고, HttpContextAccessor는 내부적으로 AsyncLocal<T>의 래퍼 클래스에 불과합니다.

AsyncLocal<T> Class
; https://docs.microsoft.com/en-us/dotnet/api/system.threading.asynclocal-1

실제로 .NET Reflector 등의 도구로 HttpContextAccessor를 보면 다음과 같습니다.

// C:\Program Files\dotnet\shared\Microsoft.AspNetCore.App\3.1.8\Microsoft.AspNetCore.Http.dll

using System;
using System.Threading;

namespace Microsoft.AspNetCore.Http
{
    // Token: 0x0200000F RID: 15
    public class HttpContextAccessor : IHttpContextAccessor
    {
        public HttpContext HttpContext
        {
            get
            {
                HttpContextAccessor.HttpContextHolder value = HttpContextAccessor._httpContextCurrent.Value;
                if (value == null)
                {
                    return null;
                }
                return value.Context;
            }
            set
            {
                HttpContextAccessor.HttpContextHolder value2 = HttpContextAccessor._httpContextCurrent.Value;
                if (value2 != null)
                {
                    value2.Context = null;
                }
                if (value != null)
                {
                    HttpContextAccessor._httpContextCurrent.Value = new HttpContextAccessor.HttpContextHolder
                    {
                        Context = value
                    };
                }
            }
        }

        private static AsyncLocal<HttpContextAccessor.HttpContextHolder> _httpContextCurrent = new AsyncLocal<HttpContextAccessor.HttpContextHolder>();

        private class HttpContextHolder
        {
            public HttpContext Context;
        }
    }

    public sealed class DefaultHttpContext : HttpContext
    {
        // ...[생략]...
    }

    public abstract class HttpContext
    {
        // ...[생략]...
    }
}

스레드를 넘나드는 정보를 다루기 때문에 당연히 AsyncLocal은 내부적으로 ExecutionContext의 처리 과정을 래핑합니다.

using System;
using System.Diagnostics.CodeAnalysis;
using System.Runtime.CompilerServices;

namespace System.Threading
{
    // Token: 0x020001F1 RID: 497
    [NullableContext(1)]
    [Nullable(0)]
    public sealed class AsyncLocal<[Nullable(2)] T> : IAsyncLocal
    {
        // Token: 0x06001DED RID: 7661 RVA: 0x000A8969 File Offset: 0x000A7769
        public AsyncLocal()
        {
        }

        // Token: 0x06001DEE RID: 7662 RVA: 0x00118FF7 File Offset: 0x00117DF7
        public AsyncLocal([Nullable(new byte[]
        {
            2,
            0,
            1
        })] Action<AsyncLocalValueChangedArgs<T>> valueChangedHandler)
        {
            this.m_valueChangedHandler = valueChangedHandler;
        }

        // Token: 0x17000663 RID: 1635
        // (get) Token: 0x06001DEF RID: 7663 RVA: 0x00119008 File Offset: 0x00117E08
        // (set) Token: 0x06001DF0 RID: 7664 RVA: 0x0011902F File Offset: 0x00117E2F
        public T Value
        {
            [return: MaybeNull]
            get
            {
                object localValue = ExecutionContext.GetLocalValue(this);
                if (localValue != null)
                {
                    return (T)((object)localValue);
                }
                return default(T);
            }
            set
            {
                ExecutionContext.SetLocalValue(this, value, this.m_valueChangedHandler != null);
            }
        }

        // Token: 0x06001DF1 RID: 7665 RVA: 0x00119048 File Offset: 0x00117E48
        void IAsyncLocal.OnValueChanged(object previousValueObj, object currentValueObj, bool contextChanged)
        {
            T previousValue = (previousValueObj == null) ? default(T) : ((T)((object)previousValueObj));
            T currentValue = (currentValueObj == null) ? default(T) : ((T)((object)currentValueObj));
            this.m_valueChangedHandler(new AsyncLocalValueChangedArgs<T>(previousValue, currentValue, contextChanged));
        }

        // Token: 0x0400070A RID: 1802
        private readonly Action<AsyncLocalValueChangedArgs<T>> m_valueChangedHandler;
    }
}




따라서, 우리도 HttpContextAccessor처럼 AsyncLocal<T>를 사용해 스레드 간의 문맥 정보 전달을 할 수 있습니다. 다음은 이것을 테스트한 간단한 예제 코드입니다.

using System;
using System.Threading;
using System.Threading.Tasks;

namespace Context1
{
    public class MyRefType
    {
        public string Name;
        public int Age;

        public override string ToString()
        {
            return $"{Name}: {Age}";
        }
    }

    class Program
    {
        static AsyncLocal<string> s_asyncText = new AsyncLocal<string>();
        static AsyncLocal<int> s_asyncInt = new AsyncLocal<int>();
        static AsyncLocal<MyRefType> s_asyncRef = new AsyncLocal<MyRefType>();

        static async Task Main(string[] args)
        {
            int count = 3;
            s_asyncRef.Value = new MyRefType { Name = $"User#{count}", Age = count };

            while (count-- > 0)
            {
                s_asyncText.Value = $"TEST#{count}";
                s_asyncInt.Value = count;

                await AsyncMethodFirst();
                
                OutputAsyncContext("AsyncMethodFirst - step4");

                ThreadPool.QueueUserWorkItem((obj) =>
                {
                    OutputAsyncContext("QueueUserWorkItem");
                });

                ThreadPool.UnsafeQueueUserWorkItem((obj) =>
                {
                    OutputAsyncContext("UnsafeQueueUserWorkItem");
                }, null);

                Thread t = new Thread(() =>
                {
                    OutputAsyncContext("new Thread");
                });
                t.Start();

                Console.WriteLine();

                s_asyncRef.Value = null;
            }

            Console.ReadLine();
        }

        private static async Task AsyncMethodFirst()
        {
            OutputAsyncContext("AsyncMethodFirst - step1");
            await Task.Delay(1000);
            OutputAsyncContext("AsyncMethodFirst - step2");

            await Task.Delay(1000);
            OutputAsyncContext("AsyncMethodFirst - step3");

            await Task.Factory.StartNew(() => {
                OutputAsyncContext("Task.Factory.StartNew"); 
            });
        }

        private static void OutputAsyncContext(string title)
        {
            Console.WriteLine($"[{Thread.CurrentThread.ManagedThreadId}] {title}: {s_asyncText.Value} {s_asyncInt.Value}, {s_asyncRef.Value}");
        }
    }
}

/* 출력 결과
[1] AsyncMethodFirst - step1: TEST#2 2, User#3: 3
[4] AsyncMethodFirst - step2: TEST#2 2, User#3: 3
[4] AsyncMethodFirst - step3: TEST#2 2, User#3: 3
[4] Task.Factory.StartNew: TEST#2 2, User#3: 3
[4] AsyncMethodFirst - step4: TEST#2 2, User#3: 3
[5] QueueUserWorkItem: TEST#2 2, User#3: 3
[6] UnsafeQueueUserWorkItem:  0,

[4] AsyncMethodFirst - step1: TEST#1 1,
[8] new Thread: TEST#2 2, User#3: 3
[7] AsyncMethodFirst - step2: TEST#1 1,
[5] AsyncMethodFirst - step3: TEST#1 1,
[5] Task.Factory.StartNew: TEST#1 1,
[5] AsyncMethodFirst - step4: TEST#1 1,
[7] UnsafeQueueUserWorkItem:  0,
[4] QueueUserWorkItem: TEST#1 1,

[5] AsyncMethodFirst - step1: TEST#0 0,
[9] new Thread: TEST#1 1,
[6] AsyncMethodFirst - step2: TEST#0 0,
[4] AsyncMethodFirst - step3: TEST#0 0,
[7] Task.Factory.StartNew: TEST#0 0,
[7] AsyncMethodFirst - step4: TEST#0 0,
[5] UnsafeQueueUserWorkItem:  0,
[4] QueueUserWorkItem: TEST#0 0,

[10] new Thread: TEST#0 0,
*/

QueueUserWorkItem, UnsafeQueueUserWorkItem과 Thread에서 보이는 결과에 따르면, AsyncLocal은 LogicalCallContext로 구현된 듯합니다. .NET 초기 시절에, 과연 LogicalCallContext가 향후 async/await에서 유용하게 사용할 거라는 것을 누가 예상했을까요? ^^

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




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

[연관 글]


donaricano-btn



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

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

비밀번호

댓글 쓴 사람
 



2021-01-05 10시59분
정성태

... 16  17  18  19  20  21  22  23  24  [25]  26  27  28  29  30  ...
NoWriterDateCnt.TitleFile(s)
12136정성태2/6/20201467Windows: 168. Windows + S(또는 Q)로 뜨는 작업 표시줄의 검색 바가 동작하지 않는 경우
12135정성태2/6/20202307개발 환경 구성: 468. Nuget 패키지의 로컬 보관 폴더를 옮기는 방법 [2]
12134정성태2/5/20203281.NET Framework: 884. eBEST XingAPI의 C# 래퍼 버전 - XingAPINet Nuget 패키지 [5]파일 다운로드1
12133정성태2/5/20201690디버깅 기술: 161. Windbg 환경에서 확인해 본 .NET 메서드 JIT 컴파일 전과 후 - 두 번째 이야기
12132정성태1/28/20202343.NET Framework: 883. C#으로 구현하는 Win32 API 후킹(예: Sleep 호출 가로채기)파일 다운로드1
12131정성태1/27/20202560개발 환경 구성: 467. LocaleEmulator를 이용해 유니코드를 지원하지 않는(한글이 깨지는) 프로그램을 실행하는 방법 [1]
12130정성태1/26/20201644VS.NET IDE: 142. Visual Studio에서 windbg의 "Open Executable..."처럼 EXE를 직접 열어 디버깅을 시작하는 방법
12129정성태1/26/20204131.NET Framework: 882. C# - 키움 Open API+ 사용 시 Registry 등록 없이 KHOpenAPI.ocx 사용하는 방법 [1]
12128정성태1/26/20201732오류 유형: 591. The code execution cannot proceed because mfc100.dll was not found. Reinstalling the program may fix this problem.
12127정성태1/25/20201729.NET Framework: 881. C# DLL에서 제공하는 Win32 export 함수의 내부 동작 방식(VT Fix up Table)파일 다운로드1
12126정성태1/25/20201842.NET Framework: 880. C# - PE 파일로부터 IMAGE_COR20_HEADER 및 VTableFixups 테이블 분석파일 다운로드1
12125정성태1/24/20201353VS.NET IDE: 141. IDE0019 - Use pattern matching
12124정성태1/23/20202491VS.NET IDE: 140. IDE1006 - Naming rule violation: These words must begin with upper case characters: ...
12123정성태1/23/20202187웹: 39. Google Analytics - gtag 함수를 이용해 페이지 URL 수정 및 별도의 이벤트 생성 방법 [2]
12122정성태1/20/20201948.NET Framework: 879. C/C++의 UNREFERENCED_PARAMETER 매크로를 C#에서 우회하는 방법(IDE0060 - Remove unused parameter '...')파일 다운로드1
12121정성태1/20/20201538VS.NET IDE: 139. Visual Studio - Error List: "Could not find schema information for the ..."파일 다운로드1
12120정성태1/19/20201852.NET Framework: 878. C# DLL에서 Win32 C/C++처럼 dllexport 함수를 제공하는 방법 - 네 번째 이야기(IL 코드로 직접 구현)파일 다운로드1
12119정성태1/17/20202202디버깅 기술: 160. Windbg 확장 DLL 만들기 (3) - C#으로 만드는 방법
12118정성태1/17/20202083개발 환경 구성: 466. C# DLL에서 Win32 C/C++처럼 dllexport 함수를 제공하는 방법 - 세 번째 이야기 [1]
12117정성태1/15/20201912디버깅 기술: 159. C# - 디버깅 중인 프로세스를 강제로 다른 디버거에서 연결하는 방법파일 다운로드1
12116정성태1/15/20201828디버깅 기술: 158. Visual Studio로 디버깅 시 sos.dll 확장 명령어를 (비롯한 windbg의 다양한 기능을) 수행하는 방법
12115정성태1/14/20201872디버깅 기술: 157. C# - PEB.ProcessHeap을 이용해 디버깅 중인지 확인하는 방법파일 다운로드1
12114정성태1/13/20202592디버깅 기술: 156. C# - PDB 파일로부터 심벌(Symbol) 및 타입(Type) 정보 열거 [1]파일 다운로드3
12113정성태1/12/20203186오류 유형: 590. Visual C++ 빌드 오류 - fatal error LNK1104: cannot open file 'atls.lib' [1]
12112정성태1/12/20201745오류 유형: 589. PowerShell - 원격 Invoke-Command 실행 시 "WinRM cannot complete the operation" 오류 발생
12111정성태1/12/20203131디버깅 기술: 155. C# - KernelMemoryIO 드라이버를 이용해 실행 프로그램을 숨기는 방법(DKOM: Direct Kernel Object Modification) [12]
... 16  17  18  19  20  21  22  23  24  [25]  26  27  28  29  30  ...