Microsoft MVP성태의 닷넷 이야기
책을 보면서 sync, async 이해가 되지 않는 부분이 있습니다. [링크 복사], [링크+제목 복사],
조회: 12578
글쓴 사람
김지우
홈페이지
첨부 파일

시작하세요! c# 10 책을 보면서 16장의 비동기 스트림을 보고있습니다.

여기서 나오는 예제중에서 p.822에 나오는 예제를 실험해본 것입니다.


class Program
{
    static async void Main(string[] args)
    {

        await foreach (int value in GenerateSequence(10)){
            Console.WriteLine($"{value} tid : {Thread.CurrentThread.ManagedThreadId}");
            
        }
        Console.WriteLine($"completed ~ : tid : {Thread.CurrentThread.ManagedThreadId}");
        
    }
    public static async IAsyncEnumerable<int> GenerateSequence(int count){
        for(int i=0; i<count; i++){
                //아래 console.writeline은 제가 실험용으로 추가한 것입니다.
        Console.WriteLine($"IAsyncEnumerable ~ : tid : {Thread.CurrentThread.ManagedThreadId}");
            await Task.Run (() => Thread.Sleep(100));
            yield return i;
        }
    
    }
}


// #nullable restore



여기서 질문을 정리해보았습니다.
질문 1.
await 을 했을 때 내부구조가


1 await 키워드를 기준으로 이전과 이후 코드를 분리함.
2 await 이전 코드가 실행됨.
3 완료될 Task에 대한 Awaiter 객체를 받아옴.
4 Awaiter 객체의 OnCompleted 이벤트에 await 이후 코드를 삽입함.
5 async 메소드는 반환되고 다른 작업을 이어나감.
6 await 연산자로 명시된 Task가 완료되면 Awaiter의 OnCompleted 이벤트가 발생하여 await 이후 코드가 실행됨.

// 변환 전 코드
private static async void AwaitRead()
{
    Console.WriteLine("Read Start");
    var mySubTask = await fs.ReadAsync(buf, 0, buf.Length); // 1. await 키워드를 기준으로 코드를 분리함
 
    Console.WriteLine($"ReadAsync Flag: {result}");
    string txt = Encoding.UTF8.GetString(buf);
    Console.WriteLine(txt);
}
 
// 변환 후 코드
private static async Task<int> AwaitRead()
{
    // 2. await 이전 코드를 실행.
    Console.WriteLine("Read Start");
 
    // 3. Task의 Awaiter 객체를 받아옴.
    var awaiter = fs.ReadAsync(buf, 0, buf.Length).GetAwaiter(); // await 호출
 
    // 4. OnCompleted 이벤트에 await 이후 코드를 삽입함.
    awaiter.OnCompleted(() => {
        // 6. Task가 완료되면 await 이후 코드들을 실행.
        var numOfBytes = awaiter.GetResult();
 
        Console.WriteLine($"ReadAsync Flag: {numOfBytes}");
        string txt = Encoding.UTF8.GetString(buf);
        Console.WriteLine(txt);
    });
 
    // 5. async 메소드는 종료
}












이렇게 된다고 하는데, 그렇다면 나중에 실행된 task(첨부된 결과 사진에서 예를들어 i==2 이고, tid는 3일 때 Thread.sleep(100) 이 실행되는것. Task A 라고 하겠습니다.) 이 먼저 실행된 task (첨부 사진에서 예를들어 i==1 이고, tid는 18일 때 Thread.sleep(100) 이 실행되는것. Task B라고 하겠습니다.)보다 작업을 빨리 마친다고 하면(sleep(100)이 아니라 그냥 다른 작업이라고 할 때) 내부구조 순서대로라고 하면, TaskA가 먼저 끝났으니 TaskA를 부른, TaskB의 tid가 18인 스레드가 TaskA 다음의 작업(yield return i) 을 실행해야할텐데, 그럼 순서가 뒤죽박죽이어야 할텐데 왜 결과는 제대로 나오는지 이해가 안됩니다.

질문 2. 그리고 먼저 실행된 TASK의 결과값을 이용해서 다음 TASK가 일을 해야 할 때는, 결국에는 동기적으로 처리하는거랑 비슷하게 흘러갈텐데 왜 async await으로 비동기처리를 하는건가요?
    
    질문 2-1. 그냥 한 스레드가 일을 하느라 “다른일”을 못하는걸 막는다기에는, 실제로 Main문에 있는
    
    - `Console.WriteLine($"completed ~ : tid : {Thread.CurrentThread.ManagedThreadId}");`
    - 를 실행하지도 않잖아요. 그럼 그냥 기다리는거아닌가요? 이게 TASK 결과를 써야하니까 기다린다고 하기에는 console.writeline(”hello”); 로 바꿔봐도 끝나고나서 실행이 되었습니다.
    
    질문 2-2. 여기서 말하는 “다른일”은 인터럽트같은것만 해당되는건가요? 만약 이벤트가 발생했을 때 일을 해야하니까 그런건가요? 그럼 그렇게 치면 그 이벤트처리문에서 TASK가 반환한 결과값을 사용해야 할 때는 또 기다리는건가요?
    
    질문 2-3. “다른일”이 정확이 어떤건가요?









[최초 등록일: ]
[최종 수정일: 2/11/2023]


비밀번호

댓글 작성자
 



2023-02-11 08시01분
일단, 질문 1에서 await foreach가 병렬 처리한다고 알고 계시는 것 같은데... 맞나요?
정성태
2023-02-13 09시31분
[글쓴이] 그러고보니 그렇네요.. 병렬처리가아니군요. 제가 왜 병렬처리로 생각하고 읽었냐면 await 했을 때 그 foreach문 자체를 담당하는 스레드가 foreach를 계속 돌지않고 반복문 돌 때마다 다른스레드가 실행하기에 그런거같습니다. 그럼 병행하지않는데 왜 반복문마다 서로다른스레드가 실행하는건가요?
[guest]
2023-02-13 09시56분
함축된 코드여서 너무 어렵게 생각하시는 것 같은데요, 결국 저 코드는 다음과 같이 평문을 반복한 걸로 이해하시면 편합니다.

await Task.Delay(100);
Console.WriteLine($"{Thread.CurrentThread.ManagedThreadId}");
await Task.Delay(100);
Console.WriteLine($"{Thread.CurrentThread.ManagedThreadId}");

그럼, 스레드가 달라지는 게 당연하지 않을까요?

(혹시, 그래도 이해가 안 되는 부분이 있으면 계속 질문해 주세요.)
정성태
2023-02-25 12시02분
[guest] 몰라서 드리는 질문인데 Thread consumer/producer 모델 하나로 밀어붙이면 안되나요?
그래도 되는데 옛날에 만들어진 소프트웨어를 개선해야 될 때 전임자의 코드를 이해해야 하므로
다양하게 배워야 하는게 맞는 것이지요? 자문자답이지만 그런 이유가 맞겠네요 전임자 코드나 후임자의 지식에 맞춰서...
[guest]
2023-02-25 01시07분
물론, 구현하기에 따라서 그렇게 해도 됩니다. 하지만 일단 이 글의 질문은 await foreach를 묻는 것이기 때문에 문맥상 어울리는 답변은 아닙니다.
정성태

... 31  32  33  34  35  36  37  38  39  40  41  42  43  44  [45]  ...
NoWriterDateCnt.TitleFile(s)
4751김민석8/16/201618152가변크기의 구조체를 SendMessage로 타 프로세스에 전송하는 방법이 있을까요? [1]
4750강준8/13/201618803ElementHost Memory Leak 현상 (아래내용과 동일 첨부 추가^^) [5]파일 다운로드1
4749강준8/11/201618229ElementHost Memory Leak 현상 [6]
4748Bere...8/3/201617184그냥 생각이 들어서 여기 글 써봅니다. [1]
4746힘찬도약8/2/201617423[asp.net] local에서 cookies값이 읽혀지지 않는 경우 [1]
4747힘찬도약8/3/201618184    답변글 [예제 첨부]: [asp.net] local에서 cookies값이 읽혀지지 않는 경우 [3]파일 다운로드1
4745힘찬도약7/27/201618352.NET 자식창 데이터를 부모창에 전달시 오류 질문드립니다. [4]파일 다운로드1
4744변찬연7/27/201618107안녕하세요 그 edge를 이용하는 데 조금 불편함이 있어서 문의드립니다 [1]
4743딸랑구아빠7/26/201617554IE 사용 시 인증 정보 계속 보내기? [1]
4741차가워7/20/201619175UWP 에서 COM 참조 불가능한가요? [6]
4740luna...7/19/201619832clickonce manifest 파일 질문 [1]
4739윤똘씨7/19/201619877정말 감동적입니다... [7]
4738닷넷초보7/7/201618363안녕하세요. C#의 개체 전달방식(참조)에 관련해서 질문 있습니다. [3]파일 다운로드1
4737beau...7/6/201620468python embedding 한 c++ 프로그램의 배포에 관해서 질문드리고 싶습니다. [1]
4736spow...7/6/201617268Property Lambda에 대한 심층 분석을 의뢰합니다 [7]
4735힘찬도약7/5/201618594.Net/Web.config에서 MSSQL을 쓰는데, MysqlSiteMap 참조오류 [3]파일 다운로드1
4734spow...6/28/201618410Visual Studio 2015 + Windows Forms 환경에서 컴파일 할 때 드물게 개발환경이 Crash 됩니다 [1]
4733feel...6/15/201618811타 서버로 소스 이전 중 [3]파일 다운로드1
4732구봉근6/14/201617067안녕하세요 [1]파일 다운로드1
4731초급개발자6/7/201619607Windows Form Application는 사라질까요? [2]
4730김시현6/4/201617552책으로 공부하던 도중 생성자에 대해서 궁금한게 생겼는데 혹시 답변좀 해주실수 있나요? [1]
4729Jeah...6/3/201619316C#.Net 프로그램에서 C++로 만들어진 dll 파일 이용관련 문의 하나 드립니다. [3]
4727링거5/30/201617473WPF MediaElement 파일 실행 후 삭제시 오류 문의 [1]파일 다운로드1
4728링거5/30/201618261    답변글 [답변]: WPF MediaElement 파일 실행 후 삭제시 오류 문의 [2]파일 다운로드1
4726spow...5/25/201617670덧글을 달고 나서 F5를 눌렀을 때 똑같은 덧글이 달리는 현상 고쳐주세요 [4]
4725Futu...5/23/201617748책 잘보고 있습니다. Task관련 질문을!!! [1]
... 31  32  33  34  35  36  37  38  39  40  41  42  43  44  [45]  ...