C#으로 이해하는 자료구조 전자책
C# 8 : 비동기 스트림

C# 5.0에서 소개된 async/await는 비동기적인 방식으로 결과를 리턴받는 기능을 쉽게 구현하도록 하였다. 이러한 async/await 기능은 결과를 한번 리턴받는 기능으로서, 연속적으로 여러 결과들을 가져오지는 않았다. 하지만, 요즘 클라우드나 IoT와 같은 데이타 소스에서 스트림을 연속적으로 가져오는 경우가 있는데, 이에 C# 8.0에서는 비동기적으로 여러 개의 연속적인 결과 스트림을 가져올 수 있는 기능을 추가하게 되었다.

C# 8.0에서 여러 결과를 비동기적으로 리턴하기 위해 IAsyncEnumerable<T> 인터페이스를 추가하였으며, 비동기 결과들을 비동기적으로 받기위해서 await foreach 라는 키워드를 도입하였다. 즉, foreach 앞에 await를 쓰면, 비동기적으로 결과들을 가져와 처리할 수 있게 한 것이다.

아래 예제에서 Device.GetTemperatures() 메서드는 연속적인 스트림 데이타를 비동기로 전달하는 메서드로서 디바이스에서 온도를 가져와서 온도 변화가 있을 때만 결과를 리턴하게 된다. 무제한으로 결과를 리턴할 수 있지만, 여기 예제에서는 100개의 데이타만 리턴하도록 하였다. 다음 TempTest() 메서드에서는 GetTemperatures() 메서드를 호출하여 비동기로 결과를 받아와서 출력하게 되는데, 여기서 foreach 앞에 await가 있는 점에 주목해야 한다. 즉, IAsyncEnumerable 을 사용하여 비동기 스트림 데이타를 받아오기 위해서는 await foreach를 사용해야 한다.


예제

class Device
{
    private int lastTemp = 0;

    public async IAsyncEnumerable<int> GetTemperatures()
    {
        for(int i=0; i<100; i++)
        {
            int currTemp = await GetTempFromDevice();
            if (currTemp != lastTemp)
            {
                lastTemp = currTemp;
                yield return lastTemp;
            }
        }
    }

    // private async Task<int> GetTempFromDevice() {...}
}


static void Main(string[] args)
{
    TempTest().Wait();
}

static async Task TempTest()
{
    var dev = new Device();
    await foreach (var temp in dev.GetTemperatures())
    {
        Console.WriteLine($"{DateTime.Now}: {temp}");
    }
}




본 웹사이트는 광고를 포함하고 있습니다. 광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.





Comment 의견/코멘트 쓰기
이메일
 *정확한 이메일이 아닐 경우 삭제될 수 있습니다
의견/코멘트
좌측의 3자리 문자들을 입력해 주십시오





아티클 모바일 링크
C# 스터디 소셜미디어