Microsoft MVP성태의 닷넷 이야기
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
 

(시리즈 글이 4개 있습니다.)
.NET Framework: 209. AutoReset, ManualReset, Monitor.Wait의 차이
; https://www.sysnet.pe.kr/2/0/1015

.NET Framework: 1120. C# - BufferBlock<T> 사용 예제
; https://www.sysnet.pe.kr/2/0/12845

.NET Framework: 1172. .NET에서 Producer/Consumer를 구현하는 기초 인터페이스 - IProducerConsumerCollection<T>
; https://www.sysnet.pe.kr/2/0/12993

.NET Framework: 1173. .NET에서 Producer/Consumer를 구현한 BlockingCollection<T>
; https://www.sysnet.pe.kr/2/0/12995




.NET에서 Producer/Consumer를 구현하는 기초 인터페이스 - IProducerConsumerCollection<T>

IProducerConsumerCollection<T>은,

IProducerConsumerCollection<T> Interface
; https://learn.microsoft.com/en-us/dotnet/api/system.collections.concurrent.iproducerconsumercollection-1

public interface IProducerConsumerCollection<T> : IEnumerable<T>, IEnumerable, ICollection
{
    void CopyTo(T[] array, int index);
    T[] ToArray();
    bool TryAdd(T item);
    bool TryTake([MaybeNullWhen(false)] out T item);
}

단순히 생각하면 기존의 ICollection 구현에서 (대표적으로) TryAdd, TryTake와 CopyTo, ToArray 메서드를 추가한 유형입니다. 즉, 이름과 어울릴법한 Producer/Consumer를 위한 특정 메서드가 추가된 것은 아닙니다. 얼핏 인터페이스의 이름만 봐서는 TryAdd/TryTake 메서드를 어떤 식으로 구현해야 할지 감도 잘 안 옵니다.

사실, 엄밀히 말하면 IProducerConsumerCollection<T>보다는 IConcurrentCollection<T>가 더 어울릴 것입니다. 또는 좀 더 직접적으로 말하면 IThreadSafeCollection도 나쁘지 않은 이름입니다. 아마도 그랬다면 TryAdd나 TryTake(를 비롯해 기타 ICollection 구현) 메서드가 thread-safe해야 한다는 것을 단번에 알아챌 수 있었을 것입니다.

물론, 대개의 경우 Producer/Consumer 구현은 스레드에 걸쳐 사용된다는 점에서 그나마 IProducerConsumerCollection의 정당성이 부여됩니다. 가령 A 스레드가 데이터를 생성하고, B 스레드에서 그 데이터를 소비하는 식이므로, 이로 인해 Thread-safe한 성격을 가진 데이터 구조가 필요하고, 그중에서도 Collection인 경우 특별히 IProducerConsumerCollection<T> 인터페이스를 구현하도록 의도한 것입니다.

실제로 "IProducerConsumerCollection<T> Interface" 문서의 예제 코드를 봐도,

public class SafeStack<T> : IProducerConsumerCollection<T>
{
    private readonly object m_lockObject = new object();
    private readonly Stack<T> m_sequentialStack;

    public SafeStack()
    {
        m_sequentialStack = new Stack<T>();
    }

    public SafeStack(IEnumerable<T> collection)
    {
        m_sequentialStack = new Stack<T>(collection);
    }

    public void Push(T item)
    {
        lock (m_lockObject) m_sequentialStack.Push(item);
    }

    public bool TryPop(out T? item)
    {
        bool rval = true;
        lock (m_lockObject)
        {
            if (m_sequentialStack.Count == 0) { item = default(T); rval = false; }
            else
            {
                item = m_sequentialStack.Pop();
            }
        }
        return rval;
    }

    public bool TryTake([MaybeNullWhen(false)] out T item)
    {
        return TryPop(out item);
    }

    public bool TryAdd(T item)
    {
        Push(item);
        return true; // Push doesn't fail
    }

    public T[] ToArray()
    {
        lock (m_lockObject)
        {
            return m_sequentialStack.ToArray();
        }
    }

    public void CopyTo(T[] array, int index)
    {
        lock (m_lockObject) m_sequentialStack.CopyTo(array, index);
    }

    public IEnumerator<T> GetEnumerator()
    {
        lock (m_lockObject)
        {
            return new Stack<T>(m_sequentialStack).GetEnumerator();
        }
    }

    IEnumerator IEnumerable.GetEnumerator()
    {
        return ((IEnumerable<T>)this).GetEnumerator();
    }

    public bool IsSynchronized
    {
        get { return true; }
    }

    public object SyncRoot
    {
        get { return m_lockObject; }
    }

    public int Count
    {
        get { return m_sequentialStack.Count; }
    }

    public void CopyTo(Array array, int index)
    {
        lock (m_lockObject) ((ICollection)m_sequentialStack).CopyTo(array, index);
    }
}

단순히 기존의 Stack<T> 자료구조에 thread-safe 기능만 얹어 SafeStack<T>를 만들어 IProducerConsumerCollection<T> 인터페이스를 적용하고 있습니다. 또한, 닷넷 BCL의 System.Collections.Concurrent 네임스페이스에서 제공하는 컬렉션도 모두,

System.Collections.Concurrent.ConcurrentBag<T>
System.Collections.Concurrent.ConcurrentQueue<T>
System.Collections.Concurrent.ConcurrentStack<T>

IProducerConsumerCollection<T>을 상속받고 있습니다.

아마 여러분들도 그동안 컬렉션 중에 thread-safe가 필요해서 동기화를 시킨 컬렉션들이 있을 것입니다. 그것들 모두가 잠재적으로는 IProducerConsumerCollection<T> 인터페이스를 상속받아도 무방한 것입니다.




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







[최초 등록일: ]
[최종 수정일: 12/6/2022]

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

비밀번호

댓글 작성자
 




... 151  152  153  154  155  156  157  158  159  160  161  162  163  [164]  165  ...
NoWriterDateCnt.TitleFile(s)
981정성태1/19/201122166개발 환경 구성: 99. SharePoint 2010 - 웹 애플리케이션 생성 시 고려해야 할 점. [1]
980정성태1/19/201133578개발 환경 구성: 98. SharePoint 2010 - Office Web Apps 설치
979정성태1/18/201126286개발 환경 구성: 97. SharePoint 2010 팀 사이트 구성
978정성태1/16/201133244.NET Framework: 203. VPN 자동 연결 및 Router 설정 추가
977정성태1/12/201132426개발 환경 구성: 96. SharePoint 2010 설치 [5]
976정성태1/11/201155249오류 유형: 111. IIS - 500.19 오류 (0x8007000d)
975정성태1/10/201129168.NET Framework: 202. CLR JIT 컴파일러가 생성한 기계어 코드 확인하는 방법 [3]파일 다운로드1
974정성태1/8/201128263.NET Framework: 201. 윈폼 TreeView - Bold 폰트 설정 후 텍스트가 잘리는 문제 [1]파일 다운로드1
973정성태1/7/201127456.NET Framework: 200. IIS Metabase와 ServerManager 개체 활용파일 다운로드1
972정성태1/7/201125496개발 환경 구성: 95. SQL Server 2008 R2 이하 버전 정보 확인
971정성태1/5/201135073.NET Framework: 199. .NET 코드 - Named Pipe 닷넷 서버와 VC++ 클라이언트 제작 [2]파일 다운로드1
970정성태1/4/201135535.NET Framework: 198. 윈도우 응용 프로그램에 Facebook 로그인 연동 [1]파일 다운로드1
969정성태12/31/201041667VC++: 45. Winsock 2 Layered Service Provider - Visual Studio 2010용 프로젝트 [1]파일 다운로드1
968정성태12/30/201027954개발 환경 구성: 94. 개발자가 선택할 수 있는 윈도우에서의 네트워크 프로그래밍 기술 [2]
967정성태12/27/201029755.NET Framework: 197. .NET 코드 - 단일 Process 실행파일 다운로드1
966정성태12/26/201027484.NET Framework: 196. .NET 코드 - 창 흔드는 효과파일 다운로드1
965정성태12/25/201029130개발 환경 구성: 93. MSBuild를 이용한 닷넷 응용프로그램의 다중 어셈블리 출력 빌드파일 다운로드1
964정성태12/21/2010144756개발 환경 구성: 92. 윈도우 서버 환경에서, 최대 생성 가능한 소켓(socket) 연결 수는 얼마일까? [14]
963정성태12/13/201029261개발 환경 구성: 91. MSBuild를 이용한 닷넷 응용프로그램의 플랫폼(x86/x64)별 빌드 [2]파일 다운로드1
962정성태12/10/201024054오류 유형: 110. GAC 등록 - Failure adding assembly to the cache: Invalid file or assembly name.
961정성태12/10/2010101634개발 환경 구성: 90. 닷넷에서 접근해보는 PostgreSQL DB [5]
960정성태12/8/201046607.NET Framework: 195. .NET에서 코어(Core) 관련 CPU 정보 알아내는 방법파일 다운로드1
959정성태12/8/201033195.NET Framework: 194. Facebook 연동 - API Error Description: Invalid OAuth 2.0 Access Token
958정성태12/7/201030382개발 환경 구성: 89. 배치(batch) 파일에서 또 다른 배치 파일을 동기 방식으로 실행 및 반환값 얻기 [2]
957정성태12/6/201033021디버깅 기술: 31. Windbg - Visual Studio 디버그 상태에서 종료해 버리는 응용 프로그램 [3]
953정성태11/28/201038192.NET Framework: 193. 페이스북(Facebook) 계정으로 로그인하는 C# 웹 사이트 제작 [5]
... 151  152  153  154  155  156  157  158  159  160  161  162  163  [164]  165  ...