Microsoft MVP성태의 닷넷 이야기
.NET Framework: 630. C# - Interlocked.CompareExchange 사용 예제 [링크 복사], [링크+제목 복사],
조회: 16328
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일

C# - Interlocked.CompareExchange 사용 예제

한 번만 실행하려고 하는 경우 간단하게는 다음과 같은 처리를 할 수 있습니다.

int _value = 0;
bool _done = false;

void func()
{
    if (_done == false)
    {
        _value++;
        _done = true;
    }
}

당연하지만, 이는 thread-safe하지 않기 때문에 다중 스레드에서 위의 func을 호출하려면 예기치 않은 동작이 발생할 수 있습니다. 위의 상황에서는 _value 값이 2 이상이 나올 수 있는데 이는 다음과 같은 코드로 테스트해 볼 수 있습니다.

using System;
using System.Collections.Generic;
using System.Threading;

class Program
{
    static int _value = 0;
    static bool _done = false;

    static void Main(string[] args)
    {
        int count = 0;

        while (true)
        {
            _value = 0;
            _done = false;

            List<Thread> list = new List<Thread>();
            for (int i = 0; i < 100; i++)
            {
                Thread t = new Thread(threadNotSafeFunc);
                list.Add(t);
            }

            foreach (var item in list)
            {
                item.Start();
            }

            foreach (var item in list)
            {
                item.Join();
            }

            if (_value != 1)
            {
                throw new ApplicationException("_value: " + _value);
            }

            Console.WriteLine(count++ + ": Tested - " + _value);
        }
    }

    private static void threadNotSafeFunc()
    {
        Thread.Sleep(1000);

        if (_done == false)
        {
            _value++;
            _done = true;
        }
    }
}

실행해 보면, 여지없이 ApplicationException 예외가 발생합니다. 이를 위해 lock 구문을 써도 되는데, 쓸데없이 참조 형 변수를 하나 둬야 하므로 이럴 땐 Interlocked.CompareExchange를 써 볼 수 있습니다. 원래는 다음과 같이 코딩할 수 있을 텐데,

int _value = 0;
bool _done = false;

void threadSafeFunc()
{
    if (Interlocked.CompareExchange(ref _done, true, false) == false)
    {
        _value++;
    }
}

아쉽게도 위의 코드를 컴파일하면 다음과 같은 오류가 발생합니다.

Error CS0452 The type 'bool' must be a reference type in order to use it as parameter 'T' in the generic type or method 'Interlocked.CompareExchange<T>(ref T, T, T)

bool 타입을 지원하지 않는 것인데, 사실 좀 이해가 안 됩니다. 어차피 CPU의 워드 타입 내에서 처리할 수 있는 형식이라서 .NET BCL 측에서 제공해줘도 무방할 텐데 굳이 뺀 이유를 모르겠습니다. 이 때문에, bool 타입은 그냥 true를 1로, false를 0으로 해석하는 전통적인 방식에 기인해서 int 타입을 써 다음과 같이 처리해 주시면 됩니다.

int _value = 0;
int _intDone = false;

void threadSafeFunc()
{
    if (Interlocked.CompareExchange(ref _intDone, 1, 0) == 0)
    {
        _value++;
    }
}

ApplicationException이 발생했던 이전 예제의 threadNotSafeFunc을 threadSafeFunc으로 변경해서 처리하면 예외 없이 잘 실행되는 것을 확인할 수 있습니다.

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




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







[최초 등록일: ]
[최종 수정일: 1/9/2017]

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

비밀번호

댓글 작성자
 



2017-01-10 04시56분
[spowner] 글 감사드립니다
[guest]
2017-01-10 08시04분
[spowner] lock 버젼으로... 한번 이렇게 짜봤습니다 -_-;

    class Program
    {
        static void Main(string[] args)
        {
            Flag doneFlag = false;

            doneFlag.RunOnce(() =>
            {
                Console.WriteLine("Yeah!");
            });
        }
    }

    public struct Flag
    {
        private bool flag;
        private object @lock;

        public Flag(bool flag)
        {
            this.flag = flag;
            @lock = new object();
        }

        public static implicit operator bool(Flag v)
        {
            return v.flag;
        }

        public static implicit operator Flag(bool v)
        {
            return new Flag(v);
        }

        public void RunOnce(Action action)
        {
            lock (@lock)
            {
                if (flag == true)
                    return;

                flag = true;
            }

            action();
        }
    }
[guest]
2017-01-10 12시40분
@spowner 재미있게 만드셨네요. ^^
정성태

... 46  [47]  48  49  50  51  52  53  54  55  56  57  58  59  60  ...
NoWriterDateCnt.TitleFile(s)
12456정성태12/15/20209279VS.NET IDE: 156. Visual Studio - "Migrate packages.config to PackageReference"
12455정성태12/15/20208786오류 유형: 693. DLL 로딩 시 0x800704ec - This Program is Blocked by Group Policy
12454정성태12/15/20209388Windows: 184. Windows - AppLocker의 "DLL Rules"를 이용해 임의 경로에 설치한 DLL의 로딩을 막는 방법 [1]
12453정성태12/14/202010329.NET Framework: 984. C# - bool / BOOL / VARIANT_BOOL에 대한 Interop [1]파일 다운로드1
12452정성태12/14/202010548Windows: 183. 설정은 가능하지만 구할 수는 없는 TcpTimedWaitDelay 값
12451정성태12/14/20209709Windows: 182. WMI Namespace를 열거하고, 그 안에 정의된 클래스를 열거하는 방법 [5]
12450정성태12/13/202010437.NET Framework: 983. C# - TIME_WAIT과 ephemeral port 재사용파일 다운로드1
12449정성태12/11/202010822.NET Framework: 982. C# - HttpClient에서의 ephemeral port 재사용 [2]파일 다운로드1
12448정성태12/11/202012445.NET Framework: 981. C# - HttpWebRequest, WebClient와 ephemeral port 재사용파일 다운로드1
12447정성태12/10/202010583.NET Framework: 980. C# - CopyFileEx API 사용 예제 코드파일 다운로드1
12446정성태12/10/202011236.NET Framework: 979. C# - CoCreateInstanceEx 사용 예제 코드파일 다운로드1
12445정성태12/8/20208613오류 유형: 692. C# Marshal.PtrToStructure - The structure must not be a value class.파일 다운로드1
12444정성태12/8/20209418.NET Framework: 978. C# - GUID 타입 전용의 UnmanagedType.LPStruct [1]파일 다운로드1
12443정성태12/8/20209311.NET Framework: 977. C# PInvoke - C++의 매개변수에 대한 마샬링을 tlbexp.exe를 이용해 확인하는 방법
12442정성태12/4/20208163오류 유형: 691. Visual Studio - Build Events에 robocopy를 사용할때 "Invalid Parameter #1" 오류가 발행하는 경우
12441정성태12/4/20207828오류 유형: 690. robocopy - ERROR : No Destination Directory Specified.
12440정성태12/4/20208868오류 유형: 689. SignTool Error: Invalid option: /as
12439정성태12/4/202010125디버깅 기술: 176. windbg - 특정 Win32 API에서 BP가 안 걸리는 경우 (2) [1]
12438정성태12/2/202010075오류 유형: 688. .Visual C++ - Error C2011 'sockaddr': 'struct' type redefinition
12437정성태12/1/20209738VS.NET IDE: 155. pfx의 암호 키 파일을 Visual Studio 없이 등록하는 방법
12436정성태12/1/202010033오류 유형: 687. .NET Core 2.2 빌드 - error MSB4018: The "RazorTagHelper" task failed unexpectedly.
12435정성태12/1/202015516Windows: 181. 윈도우 환경에서 클라이언트 소켓의 최대 접속 수 (4) - ReuseUnicastPort를 이용한 포트 고갈 문제 해결 [1]파일 다운로드1
12434정성태11/30/202010804Windows: 180. C# - dynamicport 값의 범위를 알아내는 방법
12433정성태11/29/20209863Windows: 179. 윈도우 환경에서 클라이언트 소켓의 최대 접속 수 (3) - SO_PORT_SCALABILITY파일 다운로드1
12432정성태11/29/202011254Windows: 178. 윈도우 환경에서 클라이언트 소켓의 최대 접속 수 (2) - SO_REUSEADDR [1]파일 다운로드1
12431정성태11/27/20209171.NET Framework: 976. UnmanagedCallersOnly + C# 9.0 함수 포인터 사용 시 x86 빌드에서 오동작하는 문제파일 다운로드1
... 46  [47]  48  49  50  51  52  53  54  55  56  57  58  59  60  ...