Microsoft MVP성태의 닷넷 이야기
두개의 쓰레드에서 하나의 Queue 리스트 사용시 질문드립니다. [링크 복사], [링크+제목 복사]
조회: 823
글쓴 사람
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 신호나, 각종 장비신호들을 주기적으로 받으면서 화면상에 표시하거나, 최신상태로 갱신해야하는 클래스의 일부입니다
[손님]

... [16]  17  18  19  20  21  22  23  24  25  26  27  28  29  30  ...
NoWriterDateCnt.TitleFile(s)
4959익명3/10/20182698교재 199page 델리게이트와 object를 이용한 범용 정렬 코드 [1]
4957멍멍이2/13/20183187System.Console - WriteLine함수의 제너릭 사용 [1]
4956김성대2/12/20182936asp.net 질문입니다. [1]
4955웅이2/12/20182499[삭제] WPF에서 list 속도 향상하는 방법이 있을까요?
4954초보자2/8/20183702FFT Library 사용 [1]
4950ASP열공2/5/20182716asp.net 과 C# 을 이용해서 홈페이지 만드는 질문입니다. [1]
4951ASP열공2/6/20182962    답변글 [답변]: asp.net 과 C# 을 이용해서 홈페이지 만드는 질문입니다. [1]
4952ASP열공2/7/20182933        답변글 [답변]: [답변]: asp.net 과 C# 을 이용해서 홈페이지 만드는 질문입니다. [1]
4953ASP열공2/7/20182551            답변글 [답변]: [답변]: [답변]: asp.net 과 C# 을 이용해서 홈페이지 만드는 질문입니다.
4949김성대1/31/20183414비동기 질문입니다. [3]파일 다운로드1
494880511/31/20182725C# 7.1책 보다가 질문드립니다 [1]
4947김성대1/31/20183130[삭제] 비동기 질문입니다. [2]파일 다운로드2
4946윤현수1/29/20183198비동기 TCP통신 데이터 문제 [4]파일 다운로드1
4945김성대1/26/20182590비동기 질문입니다. [1]파일 다운로드1
4944popo1/25/20182233[삭제] 스레드 안에서 Window Visibility 변경시 DialogResult 오류 질문
4943김성대1/22/20182755FromAsync 질문입니다. [1]
4942박현일1/19/20184178WPF 공부중 모르는 문법이 있어서요~^^; [2]
4941김성대1/18/20182625비동기예약어 실행오류관련입니다. [1]
4940plzheaven1/10/20182889webbrowser2 를 이용한 sns 로그인 구현 관련 문의 [2]
4939이성일1/4/20184069ClickOnce 배포 후 업데이트 시 발생하는 오류에 대해 질문 드립니다. [2]
4938김성대1/3/20183235채팅 프로그램관련 질문입니다. [9]파일 다운로드1
4937Question1/3/20184919C# CPU 사용량 한계치 늘리는 방법 [2]
4936무개1/3/20183068책 내용 인용하는 것에 관한 질문이있습니다. [1]파일 다운로드1
4935몬난아12/28/20173795IIS 및 ASP.NET 이 서버에서의 동작방식? [2]
4934Question12/26/20178434C# 해상도에 따른 자동 사이즈 조절방법이 궁금합니다. [3]
4933Kay12/15/20173296C# VS 버전 에러 질문 드립니다. [1]파일 다운로드1
... [16]  17  18  19  20  21  22  23  24  25  26  27  28  29  30  ...