Microsoft MVP성태의 닷넷 이야기
.NET Framework: 610. C# - WaitOnAddress Win32 API 사용 [링크 복사], [링크+제목 복사],
조회: 24575
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
(연관된 글이 1개 있습니다.)

C# - WaitOnAddress Win32 API 사용

Windows 8부터 새로 생긴 Win32 API 중에 WaitOnAddress를 살펴보겠습니다.

WaitOnAddress function
; https://learn.microsoft.com/en-us/windows/win32/api/synchapi/nf-synchapi-waitonaddress

이 함수를 사용하는 간단한 코드를 C++로 만들어 보면 다음과 같습니다.

#include "stdafx.h"
#include <synchapi.h>
#include <thread>

#pragma comment(lib, "Synchronization.lib")

int main()
{
    int age = 5;
    int ageCompare = 5;

    char tmpbuf[128];

    int *pAge = &age;
    int *pCompareAge = &ageCompare;

    std::thread t([&]() {
        Sleep(3000);
        *pAge = 6;
        WakeByAddressSingle(pAge);
    });

    _strtime_s(tmpbuf, 128);
    printf("%s Wait on\n", tmpbuf);

    BOOL result = WaitOnAddress(pAge, (PVOID)pCompareAge, 4, -1);

    _strtime_s(tmpbuf, 128);
    printf("%s waited: %d\n", tmpbuf, result);

    t.detach();

    return 0;
}

WaitOnAddress API를 호출하면 처음 2개의 포인터가 가리키는 값을 비교해 같으면 blocking 상태에 빠지고 다르면 곧바로 리턴합니다. 그리고 blocking 상태에 빠진 스레드를 다시 재개하려면 다른 스레드에서 WaitOnAddress의 첫 번째 인자로 넘겨준 주소 값을 WakeByAddressSingle API에 전달해 호출해야 합니다.

문서상으로 보면 WaitOnAddress는 값이 달라질 때까지 기다린다고 하지만 '값이 다르다는 조건'은 WaitOnAddress 호출 시에만 적용될 뿐 이후에는 그에 상관없이 WakeByAddressSingle, WakeByAddressAll API를 호출하기만 하면 WaitOnAddres 함수가 반환됩니다.

WakeByAddressAll function
; https://learn.microsoft.com/en-us/windows/win32/api/synchapi/nf-synchapi-wakebyaddressall

WakeByAddressSingle function
; https://learn.microsoft.com/en-us/windows/win32/api/synchapi/nf-synchapi-wakebyaddresssingle

즉, 아래의 "*pAge = 6" 코드를 주석 처리해도 WakeByAddressSingle을 호출했기 때문에 WaitOnAddress의 잠김은 풀리게 됩니다.

std::thread t([&]() {

    Sleep(3000);
    // *pAge = 6;
    WakeByAddressSingle(pAge);
});

이 함수의 의미 및 몇 가지 적용 예제는 Raymond Chen의 블로그에 자세하게 실려 있습니다.

WaitOnAddress lets you create a synchronization object out of any data variable, even a byte
; https://devblogs.microsoft.com/oldnewthing/20160823-00/?p=94145

Implementing a synchronization barrier in terms of WaitOnAddress
; https://devblogs.microsoft.com/oldnewthing/20160824-00/?p=94155

Implementing a critical section in terms of WaitOnAddress
; https://devblogs.microsoft.com/oldnewthing/20160825-00/?p=94165

Spurious wakes, race conditions, and bogus FIFO claims: A peek behind the curtain of WaitOnAddress
; https://devblogs.microsoft.com/oldnewthing/20160826-00/?p=94185

Inside STL: The atomic shared_ptr
; https://devblogs.microsoft.com/oldnewthing/20241219-00/?p=110663




물론, C#에서도 사용 가능합니다. 다음은 C++의 코드에 대응하는 C# 예제 코드입니다.

using System;
using System.Runtime.InteropServices;
using System.Threading;

namespace ConsoleApplication1
{
    class Person
    {
        public int Age;
    }

    unsafe class Program
    {
        [DllImport("kernelbase.dll", SetLastError = true)]
        static extern int WaitOnAddress(int *address, int *compareAddress, int addressSize, int dwMilliseconds);

        [DllImport("kernelbase.dll", SetLastError = true)]
        static extern void WakeByAddressSingle(int * address);

        int AgeComare;

        static void Main(string[] args)
        {
            Person person = new Person();
            person.Age = 5;

            Program pg = new Program();
            pg.AgeComare = 5;

            fixed (int* pCompareAge = &pg.AgeComare)
            fixed (int* pAge = &person.Age)
            {
                Thread t1 = new Thread(changeVarProc);
                t1.Start(new IntPtr(pAge));

                Console.WriteLine(DateTime.Now + " Wait on ");
                int result = WaitOnAddress(pAge, pCompareAge, 4, -1);
                Console.WriteLine(DateTime.Now + " Waited: " + result);
            }
        }

        private static void changeVarProc(object obj)
        {
            IntPtr ptr = (IntPtr)obj;
            int *pAge = (int *)ptr.ToPointer();

            Thread.Sleep(3000);

            // *pAge = 6;

            WakeByAddressSingle(pAge);

            Console.WriteLine("value changed: " + *pAge);
        }
    }
}

(첨부한 파일은 이 글의 소스 코드를 포함합니다.)




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

[연관 글]






[최초 등록일: ]
[최종 수정일: 4/9/2025]

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

비밀번호

댓글 작성자
 




... 76  77  78  79  [80]  81  82  83  84  85  86  87  88  89  90  ...
NoWriterDateCnt.TitleFile(s)
11997정성태7/30/201922099.NET Framework: 850. C# - Excel(을 비롯해 Office 제품군) COM 객체를 제어 후 Excel.exe 프로세스가 남아 있는 문제 [2]파일 다운로드1
11996정성태7/25/201925089.NET Framework: 849. C# - Socket의 TIME_WAIT 상태를 없애는 방법파일 다운로드1
11995정성태7/23/201930246.NET Framework: 848. C# - smtp.daum.net 서비스(Implicit SSL)를 이용해 메일 보내는 방법 [2]
11994정성태7/22/201923725개발 환경 구성: 454. Azure 가상 머신(VM)에서 SMTP 메일 전송하는 방법파일 다운로드1
11993정성태7/22/201918312오류 유형: 561. Dism.exe 수행 시 "Error: 2 - The system cannot find the file specified." 오류 발생
11992정성태7/22/201920823오류 유형: 560. 서비스 관리자 실행 시 "Windows was unable to open service control manager database on [...]. Error 5: Access is denied." 오류 발생
11991정성태7/18/201917984디버깅 기술: 128. windbg - x64 환경에서 닷넷 예외가 발생한 경우 인자를 확인할 수 없었던 사례
11990정성태7/18/201919606오류 유형: 559. Settings / Update & Security 화면 진입 시 프로그램 종료
11989정성태7/18/201918377Windows: 162. Windows Server 2019 빌드 17763부터 Alt + F4 입력시 곧바로 로그아웃하는 현상
11988정성태7/18/201922107개발 환경 구성: 453. 마이크로소프트가 지정한 모든 Root 인증서를 설치하는 방법
11987정성태7/17/201928227오류 유형: 558. 윈도우 - KMODE_EXCEPTION_NOT_HANDLED 블루스크린(BSOD) 문제 [1]
11986정성태7/17/201919836오류 유형: 557. 드라이브 문자를 할당하지 않은 파티션을 탐색기에서 드라이브 문자와 함께 보여주는 문제
11985정성태7/17/201919632개발 환경 구성: 452. msbuild - csproj에 환경 변수 조건 사용 [1]
11984정성태7/9/201927884개발 환경 구성: 451. Microsoft Edge (Chromium)을 대상으로 한 Selenium WebDriver 사용법 [1]
11983정성태7/8/201916748오류 유형: 556. nodemon - 'mocha' is not recognized as an internal or external command, operable program or batch file.
11982정성태7/8/201916641오류 유형: 555. Visual Studio 빌드 오류 - result: unexpected exception occured (-1002 - 0xfffffc16)
11981정성태7/7/201920620Math: 64. C# - 3층 구조의 신경망(분류)파일 다운로드1
11980정성태7/7/201929785개발 환경 구성: 450. Visual Studio Code의 Java 확장을 이용한 간단한 프로젝트 구축파일 다운로드1
11979정성태7/7/201921350개발 환경 구성: 449. TFS에서 gitlab/github등의 git 서버로 마이그레이션하는 방법
11978정성태7/6/201920741Windows: 161. 계정 정보가 동일하지 않은 PC 간의 인증을 수행하는 방법 [1]
11977정성태7/6/201924922오류 유형: 554. git push - error: RPC failed; HTTP 413 curl 22 The requested URL returned error: 413 Request Entity Too Large
11976정성태7/4/201919861오류 유형: 553. (잘못 인증 한 후) 원격 git repo 재인증 시 "remote: HTTP Basic: Access denied" 오류 발생
11975정성태7/4/201927868개발 환경 구성: 448. Visual Studio Code에서 콘솔 응용 프로그램 개발 시 "입력"받는 방법
11974정성태7/4/201924265Linux: 22. "Visual Studio Code + Remote Development"로 윈도우 환경에서 리눅스(CentOS 7) C/C++ 개발
11973정성태7/4/201922288Linux: 21. 리눅스에서 공유 라이브러리가 로드되지 않는다면?
11972정성태7/3/201927052.NET Framework: 847. JAVA와 .NET 간의 AES 암호화 연동 [1]파일 다운로드1
... 76  77  78  79  [80]  81  82  83  84  85  86  87  88  89  90  ...