Microsoft MVP성태의 닷넷 이야기
.NET Framework: 610. C# - WaitOnAddress Win32 API 사용 [링크 복사], [링크+제목 복사]
조회: 6172
글쓴 사람
홈페이지
첨부 파일

C# - WaitOnAddress Win32 API 사용

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

WaitOnAddress function
; https://docs.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://docs.microsoft.com/en-us/windows/win32/api/synchapi/nf-synchapi-wakebyaddressall

WakeByAddressSingle function
; https://docs.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://blogs.msdn.microsoft.com/oldnewthing/20160823-00/?p=94145

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

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




물론, 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);
        }
    }
}

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




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





[최초 등록일: ]
[최종 수정일: 10/19/2019 ]

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

비밀번호

댓글 쓴 사람
 




... [46]  47  48  49  50  51  52  53  54  55  56  57  58  59  60  ...
NoWriterDateCnt.TitleFile(s)
11086정성태11/1/20165461오류 유형: 366. The Microsoft Passport Container service terminated with the following error: General access denied error
11085정성태10/27/201614228.NET Framework: 615. C# - AForge.NET을 이용한 웹캠 영상 출력 [2]파일 다운로드1
11084정성태10/26/20165590오류 유형: 365. The User Profile Service service failed to the sign-in.
11083정성태10/26/201610421Windows: 131. 윈도우 10에서 사라진 "Adapters and Bindings" 네트워크 우선 순위 조정 기능 [1]
11082정성태10/26/20169475.NET Framework: 614. C# - DateTime.Ticks의 정밀도 [4]파일 다운로드1
11081정성태10/26/20165390오류 유형: 364. You need to fix your Microsoft Account for apps on your other devices to be able to launch apps and continue experiences on this device.
11080정성태10/24/20168632Windows: 130. Windows Server 2016 Nano 서버 설치 방법
11079정성태10/21/20165758Windows: 129. Windows Server 2016 설치 CD에 있는 Convert-WindowsImage.ps1 사용 방법 정리
11078정성태10/21/20167168Windows: 128. Windows Server 2016 Nano 서버 VHD 이미지 만드는 방법 - TP5 기준
11077정성태10/21/20167295오류 유형: 363. Active Directory 서버의 NETLOGON 서비스가 멈췄을 때 발생하는 문제
11076정성태10/21/20165291오류 유형: 362. 윈도우 백업 시 오류 - 0x80780040
11075정성태10/20/20166644Windows: 127. Convert-WindowsImage.ps1 사용 방법 정리
11074정성태10/20/201612034Windows: 126. Windows Server 2016 평가판을 정식 버전으로 라이선스 변경하는 방법
11073정성태1/6/20187981.NET Framework: 613. 윈도우 데스크톱 응용 프로그램(예: Console)에서 알림 메시지(Toast notifications) 띄우기파일 다운로드1
11072정성태10/20/20165943VC++: 102. 새로 추가한 ATL COM 객체가 regsvr32.exe로 등록이 안되는 문제
11071정성태10/20/20167091.NET Framework: 612. UWP(유니버설 윈도우 플랫폼) 앱에서 콜백 함수 내에서의 UI 요소 접근 방법 [1]
11070정성태10/21/20165431Windows: 125. 윈도우 서버 2016 마이그레이션
11069정성태3/25/201710050.NET Framework: 611. C++ 개발자들을 위한 C# Thread 동작 방식 [3]
11068정성태5/24/201910991Windows: 124. 윈도우 운영체제의 시간 함수 (5) - TSC(Time Stamp Counter)와 QueryPerformanceCounter [10]파일 다운로드1
11067정성태2/6/20188989Windows: 123. 윈도우 운영체제의 시간 함수 (4) - RTC, TSC, PM Clock, HPET Timer [2]
11066정성태2/6/20187184Windows: 122. 윈도우 운영체제의 시간 함수 (3) - QueryInterruptTimePrecise, QueryInterruptTime 함수파일 다운로드1
11065정성태2/6/20189636Windows: 121. 윈도우 운영체제의 시간 함수 (2) - Sleep 함수의 동작 방식
11064정성태10/19/20196172.NET Framework: 610. C# - WaitOnAddress Win32 API 사용파일 다운로드1
11063정성태2/6/201815725Windows: 120. 윈도우 운영체제의 시간 함수 (1) - GetTickCount와 timeGetTime의 차이점 [5]파일 다운로드1
11062정성태10/12/20165938오류 유형: 361. WCF .svc 호출 시 Could not find a base address that matches scheme net.tcp 예외
11061정성태10/12/201611395오류 유형: 360. IIS - 500.19 오류 (0x80070021)
... [46]  47  48  49  50  51  52  53  54  55  56  57  58  59  60  ...