Microsoft MVP성태의 닷넷 이야기
.NET Framework: 274. ReaderWriterLockSlim은 언제 쓰는 걸까요? [링크 복사], [링크+제목 복사],
조회: 21121
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
(연관된 글이 1개 있습니다.)

ReaderWriterLockSlim은 언제 쓰는 걸까요?


지난번 글에서 닷넷에서의 동기화 처리 방식에 대해서 설명을 했었지요.

.NET 참조 개체 인스턴스의 Object Header를 확인하는 방법
; https://www.sysnet.pe.kr/2/0/1175

일반적으로 C#에서는 다음과 같이 동기화를 합니다.

object lockInstance = new object();

lock (lockInstance)
{
   ... [공유자원 접근] ...
}

lock (...) 메커니즘은 배타적인 잠금(exclusive lock)을 걸어서 해당 자원을 보호하게 됩니다. 그런데, 가끔은 해당 자원에 대해서 거의 모든 쓰레드들이 '읽기'만 하고 가끔씩 '소수의 스레드'만 '쓰기' 작업을 한다고 했을 때 ex-lock은 왠지 아깝지 않은가 하는 생각이 들게 됩니다.

사실, lock이 필요한 이유는 상태를 변경시키는 '쓰기' 때문에 발생하는 것이지, '읽기' 만 발생하는 상황이라면 굳이 lock이 필요하지는 않습니다.

따라서 성능을 고려한다면, '읽기' 작업을 하는 스레드들 사이에서는 서로 방해를 하지 않고 있다가 '쓰기' 작업과의 연동에서만 '배타적 잠금'을 하는 것이 바람직합니다. 이런 경우가 바로 공유 잠금(shared lock)이라고 불리는 유형입니다.

어디... sh-lock이 ex-lock에 비해서 얼마나 성능이 향상되는지 한번 테스트를 해볼까요?

우선, 간단하게 카운트 루프를 도는 프로그램을 lock으로 보호해 보겠습니다.

void lockThread(object state)
{
    int counterIndex = (int)state;

    while (threadStop == false)
    {
        lock (lockCount)
        {
            counts[counterIndex]++;
        }
    }
}

위와 같은 역할을 하는 스레드를 5개 만들어서 실행하면,

for (int i = 0; i < count; i++)
{
    Thread newThread = new Thread(lockThread);
    newThread.IsBackground = true;
    newThread.Start(i);
}

counts[0...4] 배열의 카운트 값들이 스레드 내의 while 루프를 돌 때 마다 증가할 것입니다. 시간을 재서 초당 증가하는 횟수를 살펴 보니 다음과 같이 나옵니다.

11904819.7152496 
11949052.7475766 
11931037.5872447 
11933239.6103584 
11881933.1463757 

==> 초당 약 12,000,000번의 실행

그렇다면, 이제 스레드 함수에 ReaderWriterLockSlim을 사용해서 공유 잠금을 해보겠습니다.

Slim Reader/Writer (SRW) Locks 
; https://docs.microsoft.com/en-us/windows/win32/sync/slim-reader-writer--srw--locks

ReaderWriterLockSlim cacheLock = new ReaderWriterLockSlim();

void readerThread(object state)
{
    int countIndex = (int)state;
            
    while (threadStop == false)
    {
        cacheLock.EnterReadLock();

        try
        {
            counts[countIndex]++;
        }
        finally
        {
            cacheLock.ExitReadLock();
        }
    }
}

void writerThread(object state)
{
    int countIndex = (int)state;

    while (threadStop == false)
    {
        cacheLock.EnterWriteLock();

        try
        {
            counts[countIndex]++;
        }
        finally
        {
            cacheLock.ExitWriteLock();
        }
    }
}

5개의 스레드 생성 시에, 첫 번째 쓰레드에 대해서만 writerThread를 할당하고 나머지는 readerThread로 할당해 주었습니다.

for (int i = 0; i < count; i++)
{
    Thread newThread;
    
    if (i == 0)
    {
        newThread = new Thread(writerThread);
    }
    else
    {
        newThread = new Thread(readerThread);
    }

    newThread.IsBackground = true;
    newThread.Start(i);
}

자... 기대되는 군요. ^^ 이렇게 하고 실행하면 ex-lock에 비해서 얼마나 성능 향상이 있을까요?

5439175.07101596 
5398816.34136504 
5390411.53317197 
5366829.75513943 
5351321.89442379 
5344019.70797552 
5334268.38922098 

==> 초당 약 5,500,000번의 실행

오호~~~ 예상 외인가요? 무조건 잠금을 하는 ex-lock이 12,000,000번의 성능을 보였던 것에 비하면 절반도 안되는 수치를 기록하고 있습니다. 혹시... 테스트를 뭔가 잘못한 걸까요?

아닙니다. 테스트는 정확하게 했습니다. 위와 같은 상황에서는 가벼운 ex-lock이 더 좋은 성능을 보일 수밖에 없습니다.




그렇다면, lock을 점유하는 시간이 다소 길어지면 어떤 현상이 발생할까요? 이를 위해 lock 점유를 흉내내기 위해 다음과 같이 1ms에 해당하는 Thread.Sleep 시간을 스레드에 추가해 봤습니다.

void lockThread(object state)
{
    int counterIndex = (int)state;

    while (threadStop == false)
    {
        lock (lockCount)
        {
            counts[counterIndex]++;
            Thread.Sleep(1);
        }
    }
}

겨우 1ms의 지연시간을 추가한 것 뿐인데, 초당 루프 증가 수는 다음과 같이 뚝 떨어졌습니다.

998.700954608068 
998.745307936315 
998.820608186942 
998.825143635559 
998.893010223893 

==> 초당 약 1,000번의 실행

그럼 sh-lock의 경우에는 어떨까요? 이번엔 정말 기대되는 군요. ^^ 역시 동일하게 1ms의 지연 시간을 부여하고,

void readerThread(object state)
{
    int countIndex = (int)state;
            
    while (threadStop == false)
    {
        cacheLock.EnterReadLock();

        try
        {
            counts[countIndex]++;
            Thread.Sleep(1);
        }
        finally
        {
            cacheLock.ExitReadLock();
        }
    }
}

void writerThread(object state)
{
    int countIndex = (int)state;

    while (threadStop == false)
    {
        cacheLock.EnterWriteLock();

        try
        {
            counts[countIndex]++;
            Thread.Sleep(1);
        }
        finally
        {
            cacheLock.ExitWriteLock();
        }
    }
}

실행해 보면, 다음과 같은 결과를 얻을 수 있습니다.

1957.41883217647 
1900.581814786 
1912.05442748045 
1890.14059164164 
1908.65293256279 

==> 초당 약 1,900번의 실행

상황이 역전되었군요. 기대했던 데로 이번엔 ex-lock의 초당 약 1,000번도 안되는 성능에 비하면 2배 정도의 향상된 수치를 보여주고 있습니다.




이 쯤 되면, 이번 글의 제목에 썼던 내용에 대해서 어느 정도 답을 하실 수 있을 것입니다.

ReaderWriterLockSlim 클래스는, 다중 읽기/소수 쓰기의 상황에서 보호되어야 할 자원이 있는 경우에 사용할 수 있는데, 그 효과를 발휘하려면 잠금 구간 사이의 체류 시간이 있어야 합니다.

예를 들어, 다중 스레드로부터 보호해야 하는 영역에 변수 1~2개 정도 두고 하는 거라면 Interlocked.Increment / Interlocked.Decrement과 같은 것을 사용하거나 아예 가벼운 lock (...) 구문을 사용하시는 것이 성능을 위해 더욱 현명한 선택입니다.

허긴... 이렇게 머리로는 알고 있어도, ^^ 대부분의 성능 관련한 것들이 직접 측정을 하지 않으면 정확한 판단을 내릴 수 없는 경우가 많다는 것이... 문제라면 문제겠지요. ^^

(첨부된 파일은 위의 코드를 포함한 예제 프로젝트입니다.)




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

[연관 글]






[최초 등록일: ]
[최종 수정일: 6/27/2021]

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

비밀번호

댓글 작성자
 



2011-11-22 11시08분
짧은 생각으로 무조건 ReaderWriterLockSlim 클래스가 성능이 더 우월할 것이다라는 생각을 실험결과로 깨주셨군요. ㅎㅎ 감사합니다.
도움 많이 되었습니다.
스포너
2011-11-23 12시56분
[아파야낫는다] CPU점유율이 100%와 0%가 나오네요
[guest]
2020-09-12 12시33분
[질문있습니다] ReaderThread 와 WriterThread를 구분해서 예시를 들어주셨는데 두가지 모두 counts[countIndex]++;로 값을 Write하고있네요. 혹시 오타이신건지 아니면 ReadLock WriteLock 둘다 쓰기도 가능한 방식인건지 궁금합니다.
그리고 WriteLock을 취득한 상태에서 Read를 하면 안되는건가요?
[guest]
2020-09-12 01시00분
본문을 보시면, 사실 lock을 했지만 그 안의 counts[counterIndex]는 각각의 스레드만 고유하게 접근하기 때문에 동기화 대상은 아닙니다. 그냥 내부 코드에서의 실행 횟수를 체크하기 위해 쓴 것이므로 그것을 위해 lock이 하는 일은 없습니다.

그래서 답변을 드리면,

1) ReadLock을 썼다고 해서 내부에서 어떤 값에 쓰기를 할 수 없는 것은 아닙니다. 단지, 그것이 다른 스레드에서 동시에 쓰기를 하는 대상, 즉 동기화 대상이라면 쓰기를 해서는 안 됩니다.

2) WriteLock 내에서는 동기화 대상에 대해 당연히 Read/Write 모두 가능합니다.
정성태

... 16  17  18  19  20  21  22  23  24  25  26  27  28  29  [30]  ...
NoWriterDateCnt.TitleFile(s)
12890정성태12/23/20217131VC++: 152. Golang - (문자가 아닌) 바이트 위치를 반환하는 strings.IndexRune 함수
12889정성태12/22/20219564.NET Framework: 1123. C# - (SharpDX + DXGI) 화면 캡처한 이미지를 빠르게 JPG로 변환하는 방법파일 다운로드1
12888정성태12/21/20217668.NET Framework: 1122. C# - ImageCodecInfo 사용 시 System.Drawing.Image와 System.Drawing.Bitmap에 따른 Save 성능 차이파일 다운로드1
12887정성태12/21/20219799오류 유형: 777. OpenCVSharp4를 사용한 프로그램 실행 시 "The type initializer for 'OpenCvSharp.Internal.NativeMethods' threw an exception." 예외 발생
12886정성태12/20/20217614스크립트: 37. 파이썬 - uwsgi의 --enable-threads 옵션 [2]
12885정성태12/20/20217880오류 유형: 776. uwsgi-plugin-python3 환경에서 MySQLdb 사용 환경
12884정성태12/20/20216921개발 환경 구성: 620. Windows 10+에서 WMI root/Microsoft/Windows/WindowsUpdate 네임스페이스 제거
12883정성태12/19/20217823오류 유형: 775. uwsgi-plugin-python3 환경에서 "ModuleNotFoundError: No module named 'django'" 오류 발생
12882정성태12/18/20216934개발 환경 구성: 619. Windows Server에서 WSL을 위한 리눅스 배포본을 설치하는 방법
12881정성태12/17/20217393개발 환경 구성: 618. WSL Ubuntu 20.04에서 파이썬을 위한 uwsgi 설치 방법 (2)
12880정성태12/16/20217247VS.NET IDE: 170. Visual Studio에서 .NET Core/5+ 역어셈블 소스코드 확인하는 방법
12879정성태12/16/202113511오류 유형: 774. Windows Server 2022 + docker desktop 설치 시 WSL 2로 선택한 경우 "Failed to deploy distro docker-desktop to ..." 오류 발생
12878정성태12/15/20218538개발 환경 구성: 617. 윈도우 WSL 환경에서 같은 종류의 리눅스를 다중으로 설치하는 방법
12877정성태12/15/20217195스크립트: 36. 파이썬 - pymysql 기본 예제 코드
12876정성태12/14/20217027개발 환경 구성: 616. Custom Sources를 이용한 Azure Monitor Metric 만들기
12875정성태12/13/20216703스크립트: 35. python - time.sleep(...) 호출 시 hang이 걸리는 듯한 문제
12874정성태12/13/20216717오류 유형: 773. shell script 실행 시 "$'\r': command not found" 오류
12873정성태12/12/20217856오류 유형: 772. 리눅스 - PATH에 등록했는데도 "command not found"가 나온다면?
12872정성태12/12/20217676개발 환경 구성: 615. GoLang과 Python 빌드가 모두 가능한 docker 이미지 만들기
12871정성태12/12/20217735오류 유형: 771. docker: Error response from daemon: OCI runtime create failed
12870정성태12/9/20216306개발 환경 구성: 614. 파이썬 - PyPI 패키지 만들기 (4) package_data 옵션
12869정성태12/8/20218610개발 환경 구성: 613. git clone 실행 시 fingerprint 묻는 단계를 생략하는 방법
12868정성태12/7/20217184오류 유형: 770. twine 업로드 시 "HTTPError: 400 Bad Request ..." 오류 [1]
12867정성태12/7/20216855개발 환경 구성: 612. 파이썬 - PyPI 패키지 만들기 (3) entry_points 옵션
12866정성태12/7/202114268오류 유형: 769. "docker build ..." 시 "failed to solve with frontend dockerfile.v0: failed to read dockerfile ..." 오류
12865정성태12/6/20216939개발 환경 구성: 611. 파이썬 - PyPI 패키지 만들기 (2) long_description, cmdclass 옵션
... 16  17  18  19  20  21  22  23  24  25  26  27  28  29  [30]  ...