Microsoft MVP성태의 닷넷 이야기
.NET Framework: 463. PInvoke 호출을 이용한 비동기 파일 작업 [링크 복사], [링크+제목 복사],
조회: 25680
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
(연관된 글이 3개 있습니다.)

PInvoke 호출을 이용한 비동기 파일 작업

그냥 잠깐 만들어 보았는데 기록을 남기는 차원에서 써봅니다. ^^

닷넷은 비동기 메서드 호출이 잘 되어 있지만, 가끔은 PInvoke로 직접 해야 하는 경우도 있을 듯 싶어 예제 코드 삼아 만들어 보았습니다.

using Microsoft.Win32.SafeHandles;
using System;
using System.Diagnostics;
using System.IO;
using System.Runtime.InteropServices;
using System.Text;
using System.Threading;

class Program
{
    [DllImport("kernel32.dll", SetLastError = true)]
    public static extern SafeFileHandle CreateFile(
       String pipeName,
       uint dwDesiredAccess,
       uint dwShareMode,
       IntPtr lpSecurityAttributes,
       uint dwCreationDisposition,
       uint dwFlagsAndAttributes,
       IntPtr hTemplate);

    [DllImport("kernel32.dll", SetLastError = true)]
    static extern bool WriteFile(SafeFileHandle hFile, byte[] lpBuffer,
       int nNumberOfBytesToWrite, out uint lpNumberOfBytesWritten,
       [In] ref System.Threading.NativeOverlapped lpOverlapped);

    public const int FILE_FLAG_OVERLAPPED = 0x40000000;

    static void Main(string[] args)
    {
        EventWaitHandle exitEvent = new EventWaitHandle(false, EventResetMode.ManualReset);
        string txt = new string('t', 1024 * 1024 * 600);
        byte[] buf = Encoding.ASCII.GetBytes(txt);

        while (true)
        {
            File.Delete(@"C:\temp\test.txt");
            using (SafeFileHandle pHandle = CreateFile(@"c:\temp\test.txt",
                  (uint)FileAccess.ReadWrite,
                  0,
                  IntPtr.Zero,
                  (uint)2,
                  FILE_FLAG_OVERLAPPED,
                  IntPtr.Zero))
            {
                uint written;
                NativeOverlapped o = new NativeOverlapped();

                using (ManualResetEvent writeEvent = new ManualResetEvent(false))
                {
                    o.EventHandle = writeEvent.SafeWaitHandle.DangerousGetHandle();

                    Stopwatch st = new Stopwatch();
                    st.Start();
                    if (WriteFile(pHandle, buf, buf.Length, out written, ref o) == false)
                    {
                        int lastError = Marshal.GetLastWin32Error();
                        if (lastError == 997) //  ERROR_IO_PENDING == 997
                        {
                            Console.WriteLine("async");
                        }
                        else
                        {
                            // Write File Error
                            Console.WriteLine("Write File Error");
                            break;
                        }

                        WaitHandle[] waitHandles = new WaitHandle[] { writeEvent, exitEvent };
                        int completeCode = WaitHandle.WaitAny(waitHandles, Timeout.Infinite, false);
                        if (completeCode == 1) // exitEvent signaled
                        {
                            break;
                        }
                    }

                    st.Stop();
                    Console.WriteLine(st.ElapsedMilliseconds);
                }

                Thread.Sleep(1000);
            }
        }
    }
}

아울러, 아래와 같은 자료들이 있으니 읽어보시는 것도 좋겠습니다. ^^

Synchronous and Asynchronous I/O
; https://docs.microsoft.com/en-us/windows/win32/fileio/synchronous-and-asynchronous-i-o

Asynchronous Disk I/O Appears as Synchronous on Windows NT, Windows 2000, and Windows XP
; http://support.microsoft.com/kb/156932

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




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

[연관 글]






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

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

비밀번호

댓글 작성자
 




... 166  167  168  169  170  171  172  173  174  [175]  176  177  178  179  180  ...
NoWriterDateCnt.TitleFile(s)
665정성태2/7/200926030웹: 7. Internet Explorer 8 - XHR, XDR, XST, XSRF [1]
664정성태2/5/200922025Windows: 42. Concurrency Runtime
663정성태2/5/200926591.NET Framework: 123. WPF - Arial Narrow 폰트 문제
662정성태2/3/200922210VS.NET IDE: 59. HyperAddin 도구 사용 설명 [1]
661정성태2/3/200925888오류 유형: 68. msxml6r.dll 설치 오류
660정성태2/3/200924604Windows: 41. UAC 보안 취약 [2]
659정성태2/2/200935881오류 유형: 67. ClickOnce 응용 프로그램이 실행되지 않을 때.
658정성태2/1/200928039Team Foundation Server: 30. 소스 서버 보안
657정성태2/1/200930984Windows: 40. Q1 Ultra + Windows 7 베타
656정성태2/1/200932284디버깅 기술: 24. .NET JIT 최적화 코드 생성 제어
655정성태1/31/200928768Windows: 39. IE8 표준 모드 [4]
653정성태1/29/200923553.NET Framework: 122. XML Serializer를 이용한 값 복사: 성능은 어떨까!파일 다운로드1
652정성태1/22/200924179.NET Framework: 121. WPF - PrintTicket provider failed to bind to printer.
651정성태1/20/200921741.NET Framework: 120. 타입이 다른 배열끼리의 변환
650정성태1/19/200933522COM 개체 관련: 21. C/C++ 프로젝트에 /clr 옵션 적용으로 인한 COM 개체 사용 오류
649정성태1/18/200931152Windows: 38. Q1U UMPC에 Windows 7 베타 설치하기
648정성태1/18/200929739Windows: 37. Windows PE를 USB 메모리에 적용
647정성태1/18/200939959Windows: 36. Windows PE ISO 이미지 만들기 [1]
646정성태1/18/200932956디버깅 기술: 23. COMPLUS_ZapDisable - JIT 최적화 코드 생성 제어 [1]
645정성태1/11/200931596Windows: 35. 서명되지 않은 드라이버 로딩 방법
644정성태1/11/200922685Windows: 34. VPC 설치 후기 [2]
643정성태1/10/200928037Windows: 33. Windows 7 베타와 VMA 충돌 [1]
642정성태1/8/200926772개발 환경 구성: 34. Sysinternals의 모든 툴을 한번에 업데이트 하는 방법 [1]
641정성태1/7/200923806기타: 27. D820 - A09 바이오스 업데이트 프로그램 패치 [2]
640정성태1/4/200925582Team Foundation Server: 29. ClickOnce 응용 프로그램 배포를 Team Build에 추가.
639정성태1/4/200923539Team Foundation Server: 28. PFX 코드 서명을 포함한 프로젝트의 팀 빌드 실패 - MSB4018
... 166  167  168  169  170  171  172  173  174  [175]  176  177  178  179  180  ...