Microsoft MVP성태의 닷넷 이야기
두개의 쓰레드에서 하나의 Queue 리스트 사용시 질문드립니다. [링크 복사], [링크+제목 복사]
조회: 664
글쓴 사람
hbline
홈페이지
첨부 파일
 
안녕하세요. 이곳에서 정말 많은 도움을 받고 있는 한 개발자입니다. 항상 감사한 마음으로 다녀갑니다..

이번에 특정 상황에서 쓰려고하는 순환 Queue형태의 Class 하나를 적용시켜보려합니다.
먼저 들어온 데이터를 먼저 처리해야하는 상황이어서, Queue형태의 자료구조를 택하였고,
가벼운 데이터들이 많지만 들어오는 데이터 주기가 1초에 100번이상도 가능합니다.
들어온 데이터는 A 쓰레드에서 빠르게 누적시키고 빠지며,
데이터 처리는 B 쓰레드에서 하도록 하였습니다.

[예외처리나 구현은 최대한 간략히 보이도록 제거 및 정리하였습니다]
private class CircleQueue<T>
{
    private const int MAX = 64;

    private readonly int mask = MAX - 1;
    private readonly T[] bucket = new T[MAX];
    private int enqIndex = 0;
    private int deqIndex = 0;

    public void Enqueue(T item)
    {
        bucket[enqIndex] = item;
        enqIndex = enqIndex + 1 & mask;
    }

    public bool Dequeue(out T item)
    {
        if (deqIndex != enqIndex)
        {
            item = bucket[deqIndex];
            deqIndex = deqIndex + 1 & mask;
            return true;
        }
        else
        {
            item = default;
            return false;
        }
    }
}

A 쓰레드 에서는 알수 없는 시간간격으로 Enqueue를 발생시키고,
B 쓰레드 에서는 특정 간격으로 Dequeue를 발생시킵니다.
A,B 외의 쓰레드에서 위 함수를 엑세스 할일은 없습니다.

Enqueue 시 데이터 입력 후 enqIndex의 카운팅으로 마치며,
Dequeue 시 데이터 취득 후 deqIndex의 카운팅으로 마칩니다.
deqIndex가 enqIndex를 쫓아가며 누적된 bucket 데이터를 가져오는 형태입니다.

여기서 카운팅 변수로 쓰이는 int 유형의 원자성에 대해 찾아보았고,
CLI 사양에 int 유형보다 크지 않은 읽기, 쓰기 작업에 대해 원자성이 보장된다고 하니
Dequeue 시 enqIndex가 잘못된 값으로 읽힐 일은 없다고 생각됩니다.
그러면 lock 구문 없이 Dequeue의 데이터는 항상 올바른 순서와 데이터를 보장할 수 있을까요?

의문이 드는 부분은 컴파일러가 최적화를 한후에도 위와같은 코드 순서가 보장이 되는지..
만약 bucket의 타입이 원자성이 보장되지 않는 타입이라면 카운팅은 되었어도
아직 bucket에 완전히 입력이 되지 않는 상태가 발생할 수 있을까요?






[최초 등록일: ]
[최종 수정일: 10/21/2019 ]


비밀번호

댓글 쓴 사람
 



2019-10-21 12시03분
그런데, 위의 코드에서 EnQ가 기존 데이터를 덮어써도 괜찮은 구조인가요? 게다가 덮어쓴 경우에는 가장 마지막에 덮어쓴 것을 deqIndex가 가리킬 것이므로 그때부터는 순서가 엉망이 될 것입니다.

일단 위와 같은 코드가 전부이고 그것이 의도된 거라고 가정했을 때, EnQ와 DeQ가 각각 다른 스레드로 분리돼 접근이 된다면 동기화 상으로는 문제가 없습니다.

참고로 CLI 사양에 int 유형보다 .... 라고 했지만 정확히는 CPU 워드만큼입니다. 즉 32비트의 경우 int, 64비트의 경우에는 long 크기까지 원자성이 보장됩니다.
정성태
2019-10-21 01시48분
[hbline] 네 감사합니다. 동기화 상으로 문제가 없다니, 걱정없이 진행해보도록 하겠습니다.
여기서 bucket은 Dispose가 필요없는 타입들이므로 덮어쓰도록 하였습니다. 주로 string 이나 byte, struct 구조입니다.
그리고 말씀하신대로 EnQ가 DeQ보다 더 많이 일어난다면 enqIndex가 deqIndex와 같아지거나 따라 잡는 경우도 있습니다.
구조상 enqIndex가 deqIndex를 따라 잡는 일은 없지만, 만약 발생한다하면 따라잡힌 시점부터의 데이터를 취득해도 문제는 없습니다
신뢰도가 필요한 데이터는 아니고 GPS 신호나, 각종 장비신호들을 주기적으로 받으면서 화면상에 표시하거나, 최신상태로 갱신해야하는 클래스의 일부입니다
[손님]

1  2  3  4  5  6  7  8  9  [10]  11  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
5079jhp10/30/20182068이 소스에 API후킹 소스를 추가하고 싶은데 어떻게 해야될지 모르겠어요. [4]
5078꾸엉10/29/20181512C# 7.1 185~187p 질문입니다. [2]
5077윤현수10/29/20182877setup파일 설치 이후 실행이 안되는 현상 [11]
5074진우10/28/20181541C# 생성과 동시에 초기화 하는 코드 문의 [2]
5073돌고래10/27/20181684c# 공부 방향 질문 드립니다. [3]
5072엔벌잉10/24/20182047C# textbox, button질문입니다! [4]파일 다운로드1
5071엔벌잉10/23/20181963C#윈도우폼 질문입니다!! [2]
5070진우10/17/20181564Visual Studio 서비스팩과 업데이트 차이 문의 [2]
5069감자10/12/20181795빌드 구성을 재설정하는 방법이 있을까요? [1]파일 다운로드1
5068누오10/10/20181574ASP Core 2.0 에서 dll안에 있는 뷰 읽어들이는 방법? [1]
5067김정민10/5/20181595다른 윈도우가 깨지는 현상을 막을 수 있을까요 [3]
5066로니브10/4/20181829ASP.NET MVC에서 View 파일 숨기는법? 보안처리 하는법? 관련 질문.. [1]
5065키모10/1/20181470문자 질문입니다. [3]
5064로니브10/1/20181886클래스 라이브러리에서 .cshtml파일을 추가하는 방법은 없나요? [3]
5063진우9/28/20181613ADO.net 과 Entity Framework 차이 문의 [2]
5062테스트9/27/20181486C# import file 의 구조체 배열 선언 및 호출에 대해 문의. [3]
5061안녕하세요9/13/20181763c# 프로그래밍 관련 문의 [1]
5060임민재9/8/20181681c# install 파일 생성 시 문제가 발생하였습니다 [1]파일 다운로드1
50599/7/20181518Winform TextBox 포커스 유지하는 방법 질문 [파일첨부] [1]파일 다운로드1
50589/5/20182505Winform TextBox 포커스 유지하는 방법 질문 [3]
5056박종윤8/30/20182532c# dll을 C++에서 사용 시 event 호출 [4]파일 다운로드1
5055초보자8/29/20181978asp.net 에서 다른 서버의 iis를 stop하는 batch file을 실행시키는데 동작하지 않습니다. [5]
5054사도신8/29/20181678[wpf] textbox insert overite 모드시에 [4]파일 다운로드1
5053엿장수8/26/20181539directshow filter 에서의 IMediaSample 의 시간에대한질문입니다 [1]
5052오명현8/26/20181921Tcp소켓 실습 Exeption 도와주세요! [4]파일 다운로드1
5049오명현8/23/20181664책 477페이지 내용 중 이해가 안가는 부분이 있어 질문드립니다. [1]
1  2  3  4  5  6  7  8  9  [10]  11  12  13  14  15  ...