Microsoft MVP성태의 닷넷 이야기
.NET Framework: 456. C# - CAS를 이용한 Lock 래퍼 클래스 [링크 복사], [링크+제목 복사],
조회: 23378
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
(연관된 글이 1개 있습니다.)

C# - CAS를 이용한 Lock 래퍼 클래스

기왕 lock-free를 통해 CAS(Compare-And-Swap)을 다뤄본 김에,

[부연] Lock-Free 알고리즘은 과연 빠른가?
; https://www.sysnet.pe.kr/2/0/1736

lock-free 방식이 과연 성능에 얼마나 도움이 될까요?
; https://www.sysnet.pe.kr/2/0/1458

간단하게 클래스로 래핑해 볼까요? ^^ 대충 다음과 같은 정도로 만들 수 있습니다.

public class CASLock : IDisposable // .NET IDisposable 처리 정리
                                    // ; https://www.sysnet.pe.kr/2/0/347
{
    int _lockVariable = 0;
    bool _disposed = true;

    public IDisposable Lock()
    {
        while (Interlocked.CompareExchange(ref _lockVariable, 1, 0) != 0) { }
        _disposed = false;
        return this;
    }

    void Free(bool disposing)
    {
        _lockVariable = 0;
        _disposed = true;
    }

    public void Dispose()
    {
        Free(true);
        GC.SuppressFinalize(this);
    }

    ~CASLock()
    {
#if DEBUG
        if (false == _disposed)
        {
            throw new ApplicationException("CASLock.Dispose() was not called!");
        }
#endif

        Free(false);
    }
}

사용법은 using을 통해 기존의 lock문과 거의 유사하게 쓸 수 있습니다.

CASLock lockA = new CASLock();

using (lockA.Lock())
{
    Console.WriteLine("locked");
}

전형적인 dead-lock 상황을 연출해 볼까요? ^^

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

namespace ConsoleApplication2
{
    class Program
    {
        CASLock lockA = new CASLock();
        CASLock lockB = new CASLock();

        static void Main(string[] args)
        {
            Program p = new Program();

            Thread t1 = new Thread(p.t1);
            Thread t2 = new Thread(p.t2);

            t1.Name = "lockAB";
            t2.Name = "lockBA";

            t1.Start();
            t2.Start();

            t1.Join(); // t1 스레드는 절대로 종료하지 않으므로 Join문은 반환하지 않음.
            t2.Join();
        }

        // Thread 1 
        void t1()
        {
            using (lockA.Lock())
            {
                Thread.Sleep(2000);
                using (lockB.Lock()) // Thread2의 t2메서드에서 이미 lock을 소유하고 있으므로 block
                {
                    Console.WriteLine("lockA -> lockB");
                }
            }
        }

        // Thread 2 
        void t2()
        {
            using (lockB.Lock())
            {
                Thread.Sleep(2000);
                using (lockA.Lock()) // Thread1의 t1메서드에서 이미 lock을 소유하고 있으므로 block
                {
                    Console.WriteLine("lockB -> lockA");
                }
            }
        }
    }
}

여기서, Thread.Abort 메서드로 특정 스레드를 강제 종료하는 것으로 우리가 만든 CASLock 클래스의 안정성 테스트를 해보겠습니다.

static void Main(string[] args)
{
    Program p = new Program();

    Thread t1 = new Thread(p.t1);
    Thread t2 = new Thread(p.t2);

    t1.Name = "lockAB";
    t2.Name = "lockBA";

    t1.Start();
    t2.Start();

    int retryCount = 5;
    while (retryCount-- > 0)
    {
        Console.Write(".");
        Thread.Sleep(1000);
    }

    t1.Abort(); // Thread1 강제 종료

    t1.Join();
    t2.Join();
}

테스트 코드를 실행시켜 보면 5초 후에 t1.Abort가 호출되고 이는 해당 스레드에 ThreadAbortException 예외를 발생시킵니다. 따라서 t1 메서드 내부의 using 문에서 IDisposable.Dispose 메서드가 실행되고 이로 인해 lockA의 잠금이 해제됩니다.

그런데, Native Win32 API인 TerminateThread를 호출하면 어떻게 될까요?

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

namespace ConsoleApplication2
{
    class Program
    {
        [DllImport("kernel32.dll")]
        static extern bool TerminateThread(IntPtr hThread, uint dwExitCode);

        [Flags]
        public enum ThreadAccess : int
        {
            TERMINATE = (0x0001),
        }

        [DllImport("kernel32.dll", SetLastError = true)]
        static extern IntPtr OpenThread(ThreadAccess dwDesiredAccess, bool bInheritHandle, int dwThreadId);

        static IntPtr _threadAHandle = IntPtr.Zero;

        static void Main(string[] args)
        {
            Program p = new Program();

            Thread t1 = new Thread(p.t1);
            Thread t2 = new Thread(p.t2);

            t1.Name = "lockAB";
            t2.Name = "lockBA";

            t1.Start();
            t2.Start();

            int retryCount = 5;
            while (retryCount-- > 0)
            {
                Console.Write(".");
                Thread.Sleep(1000);
            }

            Console.WriteLine("Terminating...: " + Process.GetCurrentProcess().Threads.Count);
            TerminateThread(_threadAHandle, 100);
            Console.WriteLine("Terminated.: " + Process.GetCurrentProcess().Threads.Count);

            t1.Join();
            t2.Join();
        }

        CASLock lockA = new CASLock();
        CASLock lockB = new CASLock();


        // Thread 1 
        void t1()
        {
            _threadAHandle = OpenThread(ThreadAccess.TERMINATE, false, AppDomain.GetCurrentThreadId());
            using (lockA.Lock())
            {
                Thread.Sleep(2000);
                using (lockB.Lock())
                {
                    Console.WriteLine("lockA -> lockB");
                }
            }
        }

        // Thread 2 
        void t2()
        {
            using (lockB.Lock())
            {
                Thread.Sleep(2000);
                using (lockA.Lock())
                {
                    Console.WriteLine("lockB -> lockA");
                }
            }
        }
    }
}

이런 경우, Thread1이 종료되었음에도 불구하고 lock은 여전히 잠김상태로 남게 됩니다. (기존의 Monitor.Enter/Exit를 해도 동일하게 문제가 나타납니다.) 이는 LockFree 클래스의 안정성에 문제가 있는 것은 아니고 TerminateThread API는 때로 이렇게 위험한 상황을 연출하기 때문에 문서에는 다음과 같이 주의 사항이 나옵니다.

TerminateThread function
; https://learn.microsoft.com/en-us/windows/win32/api/processthreadsapi/nf-processthreadsapi-terminatethread

TerminateThread is a dangerous function that should only be used in the most extreme cases. You should call TerminateThread only if you know exactly what the target thread is doing, and you control all of the code that the target thread could possibly be running at the time of the termination. For example, TerminateThread can result in the following problems:
  • If the target thread owns a critical section, the critical section will not be released.
  • If the target thread is allocating memory from the heap, the heap lock will not be released.
  • If the target thread is executing certain kernel32 calls when it is terminated, the kernel32 state for the thread's process could be inconsistent.
  • If the target thread is manipulating the global state of a shared DLL, the state of the DLL could be destroyed, affecting other users of the DLL.
A thread cannot protect itself against TerminateThread, ...

보시는 것처럼, .NET 세계에서뿐만 아니라 Win32 SDK 세계에서도 TerminateThread API를 잘못 사용하면 저렇게 많은 문제를 발생할 수 있습니다. ^^ 한마디로, 모든 상황을 잘 이해하고 있지 않은 상황에서는 절대 써서는 안될 API입니다.

(첨부한 프로젝트는 위의 예제를 포함하고 있습니다.)




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

[연관 글]






[최초 등록일: ]
[최종 수정일: 9/16/2023]

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

비밀번호

댓글 작성자
 




... 61  62  63  64  65  66  [67]  68  69  70  71  72  73  74  75  ...
NoWriterDateCnt.TitleFile(s)
12297정성태8/25/202019341개발 환경 구성: 503. SHA256 테스트 인증서 생성 방법
12296정성태8/24/202020394.NET Framework: 933. C# - ETW 관련 Win32 API 사용 예제 코드 (2) NT Kernel Logger파일 다운로드1
12295정성태8/24/202019226오류 유형: 639. Bitvise - Address is already in use; bind() in ListeningSocket::StartListening() failed: Windows error 10013: An attempt was made to access a socket ,,,
12293정성태8/24/202020201Windows: 171. "Administered port exclusions" 설명
12292정성태8/20/202023464.NET Framework: 932. C# - ETW 관련 Win32 API 사용 예제 코드 (1)파일 다운로드2
12291정성태8/15/202020008오류 유형: 638. error 1297: Device driver does not install on any devices, use primitive driver if this is intended.
12290정성태8/11/202021360.NET Framework: 931. C# - IP 주소에 따른 국가별 위치 확인 [8]파일 다운로드1
12289정성태8/6/202018321개발 환경 구성: 502. Portainer에 윈도우 컨테이너를 등록하는 방법
12288정성태8/5/202016620오류 유형: 637. WCF - The protocol 'net.tcp' does not have an implementation of HostedTransportConfiguration type registered.
12287정성태8/5/202018902오류 유형: 636. C# - libdl.so를 DllImport로 연결 시 docker container 내에서 System.DllNotFoundException 예외 발생
12286정성태8/5/202020351개발 환경 구성: 501. .NET Core 용 container 이미지 만들 때 unzip이 필요한 경우
12285정성태8/4/202019289오류 유형: 635. 윈도우 10 업데이트 - 0xc1900209 [2]
12284정성태8/4/202018691디버깅 기술: 169. Hyper-V의 VM에 대한 메모리 덤프를 뜨는 방법
12283정성태8/3/202020399디버깅 기술: 168. windbg - 필터 드라이버 확인하는 확장 명령어(!fltkd) [2]
12282정성태8/2/202017468디버깅 기술: 167. windbg 디버깅 사례: AppDomain 간의 static 변수 사용으로 인한 crash (2)
12281정성태8/2/202021618개발 환경 구성: 500. (PDB 연결이 없는) DLL의 소스 코드 디버깅을 dotPeek 도구로 해결하는 방법
12280정성태8/2/202019166오류 유형: 634. 오라클 (평생) 무료 클라우드 VM 생성 후 SSH 접속 시 키 오류 발생 [2]
12279정성태7/29/202021622개발 환경 구성: 499. 닷넷에서 접근해보는 InterSystems의 Cache 데이터베이스파일 다운로드1
12278정성태7/23/202017676VS.NET IDE: 149. ("Binary was not built with debug information" 상태로) 소스 코드 디버깅이 안되는 경우
12277정성태7/23/202019801개발 환경 구성: 498. DEVPATH 환경 변수의 사용 예 - .NET Reflector의 (PDB 연결이 없는) DLL의 소스 코드 디버깅
12276정성태7/23/202019558.NET Framework: 930. 개발자를 위한 닷넷 어셈블리 바인딩 - DEVPATH 환경 변수
12275정성태7/22/202021360개발 환경 구성: 497. 닷넷에서 접근해보는 InterSystems의 IRIS Data Platform 데이터베이스파일 다운로드1
12274정성태7/21/202020453개발 환경 구성: 496. Azure - Blob Storage Account의 Location 이전 방법 [1]파일 다운로드1
12273정성태7/18/202023647개발 환경 구성: 495. Azure - Location이 다른 웹/DB 서버의 경우 발생하는 성능 하락
12272정성태7/16/202016070.NET Framework: 929. (StrongName의 버전 구분이 필요 없는) .NET Core 어셈블리 바인딩 규칙 [2]파일 다운로드1
12271정성태7/16/202019616.NET Framework: 928. .NET Framework의 Strong-named 어셈블리 바인딩 (2) - 런타임에 바인딩 리디렉션파일 다운로드1
... 61  62  63  64  65  66  [67]  68  69  70  71  72  73  74  75  ...