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

.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

비밀번호

댓글 작성자
 




1  2  3  4  5  [6]  7  8  9  10  11  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
13061정성태5/16/20221385.NET Framework: 2013. C# - FILE_FLAG_OVERLAPPED가 적용된 파일의 읽기/쓰기 시 Position 관리파일 다운로드1
13060정성태5/15/20221666.NET Framework: 2012. C# - async/await 그리고 스레드 (3) Task.Delay 재현파일 다운로드1
13059정성태5/14/20221590.NET Framework: 2011. C# - CLR ThreadPool의 I/O 스레드에 작업을 맡기는 방법파일 다운로드1
13058정성태5/13/20221370.NET Framework: 2010. C# - ThreadPool.SetMaxThreads 사용법
13057정성태5/12/20222464오류 유형: 812. 파이썬 - ImportError: cannot import name ...
13056정성태5/12/20221475.NET Framework: 2009. C# - async/await 그리고 스레드 (2) MyTask의 호출 흐름 [2]파일 다운로드1
13055정성태5/11/20222192.NET Framework: 2008. C# - async/await 그리고 스레드 (1) MyTask로 재현 [10]파일 다운로드1
13054정성태5/11/20221630.NET Framework: 2007. C# - 10진수 숫자를 담은 문자열을 숫자로 변환하는 방법 [11]파일 다운로드1
13053정성태5/10/20221206.NET Framework: 2006. C# - GC.KeepAlive 메서드의 역할
13052정성태5/9/20221247.NET Framework: 2005. C# - 생성한 참조 개체가 언제 GC의 정리 대상이 될까요?
13051정성태5/8/20221149.NET Framework: 2004. C# XingAPI - ACF 검색 결과로 구한 CSV 파일을 통해 퀀트 종목 찾기파일 다운로드1
13050정성태5/6/20221226.NET Framework: 2003. C# - COM 개체의 이벤트 핸들러에서 발생하는 예외에 대한 CLR의 특별 대우파일 다운로드1
13049정성태5/6/2022942오류 유형: 811. GoLand - Error: Cannot find package
13048정성태5/6/20221136오류 유형: 810. "ASUS TUF GAMING B550M-PLUS (WI-FI)" 모델에서 블루투스 장치가 인식이 안 되는 문제
13047정성태5/6/20221032오류 유형: 809. Speech Recognition could not start
13046정성태5/5/20221268.NET Framework: 2002. C# XingAPI - ACF 파일을 이용한 퀀트 종목 찾기(t1857)
13045정성태5/5/20221159.NET Framework: 2001. C# XingAPI - 주식 종목에 따른 PBR, PER, ROE 구하는 방법(t3341 예제)
13044정성태5/4/20221523오류 유형: 808. error : clang++ exited with code 127
13043정성태5/3/20221055오류 유형: 807. C# - 닷넷 응용 프로그램에서 Informix DB 사용 시 오류 메시지 정리
13042정성태5/3/20221172.NET Framework: 2000. C# - 닷넷 응용 프로그램에서 Informix DB 사용 방법파일 다운로드1
13041정성태4/28/20221043개발 환경 구성: 642. Informix 데이터베이스 docker 환경 구성
13040정성태4/27/20221508VC++: 156. 비주얼 스튜디오 - Linux C/C++ 프로젝트에서 openssl 링크하는 방법
13039정성태4/27/20221388.NET Framework: 1999. C# - Playwright를 이용한 간단한 브라우저 제어 실습
13038정성태4/26/20221106오류 유형: 806. twine 실행 시 ConfigParser.ParsingError: File contains parsing errors: /root/.pypirc
13037정성태4/25/20221250.NET Framework: 1998. Azure Functions를 사용한 간단한 실습
13036정성태4/24/20221579.NET Framework: 1997. C# - nano 시간을 가져오는 방법 [2]
1  2  3  4  5  [6]  7  8  9  10  11  12  13  14  15  ...