Microsoft MVP성태의 닷넷 이야기
두개의 쓰레드에서 하나의 Queue 리스트 사용시 질문드립니다. [링크 복사], [링크+제목 복사]
조회: 837
글쓴 사람
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)
5374손님8/27/2020347시작하세요! C# 8.0 프로그래밍 책에 오타가 있습니다. [1]
5373agj8/26/2020241System.Single::ToString()함수의 IL코드를 보았는데 ldnull, throw가 전부입니다. 왜 이렇게 짧죠? [2]
5372민성8/24/2020296안녕하세요 WPF 웹브라우저 컨트롤에서 웹브라우저 자체를 엣지로 할 수가 있나요? [2]
5371서현준8/11/2020242Hyper-V 내부 네트워크 환경 중, VM 에서 인터넷 접속 [1]
5370독자8/11/2020217.net createobject 관련 질문입니다.. [4]
5369독자8/10/2020261c# 8.0 프로그래밍 책에 대한 질문 드립니다 [1]
5368손님8/10/2020277시작하세요! C# 8.0 프로그래밍 책에 오타가 있습니다. [1]
5367박순기8/8/2020224디버깅 시 반전되는 부분 글 색상이나 배경색을 변경하는 방법 [3]파일 다운로드1
5366간절함8/7/2020274하나의 솔루션에서, 32비트 프로젝트에서 다른 64비트 프로젝트 참조하는 방법 궁금합니다. [4]
5365영귤8/6/2020221TimeSpan 구할 때 시간대를 바꿔도 같은 값이 나오는 것 같습니다. [1]
5364박순기8/5/2020258visual studio의 menu bar font size 변경방법 문의 [2]파일 다운로드1
5363클락8/1/2020401c# 9.0 출간 준비 중이신가요? [2]
5361하태7/29/2020232안녕하세요! 바이너리데이터 파싱 질문 드리겠습니다!. [2]
5360진우7/28/2020334엑셀에서 발생하는 모든 이벤트를 감지 할수 있는지 궁금합니다. [7]파일 다운로드1
5358홍길동7/22/2020202개체에서 open 속성이나 매서드가 지원 되지 않읍니다.라고 오류창이 뜨는데. [1]
5357손동섭7/22/2020332책 예제코드... [3]
5355neska7/21/2020208안녕하세요 문의 드립니다 [1]
5354민성7/15/2020319안녕하세요 db연결 문자 보안 [2]
5353형성재7/14/2020238Visual Studio Setup Project에서 VC++2010재배포패키지설치 [4]
5352윤식7/10/2020550닷넷코어 빌드 시 runtimeconfig 파일을 없앨 수 있는지.. [4]
5351runryan7/2/2020488C# 에서 C++ dll 병렬 사용 [1]
5350홍성호6/29/2020614C++에서 정의된 구조체(공유메모리)를 C#으로 공유메모리에서 구조체 변환시 에러가 발생 합니다. [1]파일 다운로드1
5349jerome.lee6/24/2020352logon credential provider 관련 문의드립니다. [1]
5348776/19/2020429시작하세요 C# 8.0프로그래밍 책에 대한 질문입니다. [8]
5347민성6/19/2020329안녕하세요 WPF Binding에서요 [1]
5346dimohy6/18/2020330Task.WhenAll() 메소드를 이용한 코드를 좀더 짧게 사용하고 싶은데 다른 표현이 있을까요? [3]
1  [2]  3  4  5  6  7  8  9  10  11  12  13  14  15  ...