async await 사용시 조심해야 할 점

Task가 무한정 늘어나는 현상

async await를 사용할 때 Main Thread는 await를 만나면 현재 위치에서 탈출하여 async method를 호출하던 위치로 돌아간다. 그리고 새로 생성된 thread가 (앞으로 new Thread라고 부름) await아래 구문을 실행한다.

만약 new Thread가 while(true)같은 무한루프에 빠지게 된다면 Thread는 없어지지 않고 계속 남아있는데 문제는 'Task.Add' 를 사용할 때 Thread가 무한루프 안에서 이 문구를 계속 실행하게 된다면 Task 가 무한정 늘어나게 된다.

만약에 아래 있는 코드를 그대로 시행 시키면 tasks.Add(Task.Run(() => DeviceConnection(obj))); 여기서 생성된 task가 죽지 않고 그대로 남는다. 그러면 아랫줄에 var results = await Task.WhenAll(tasks); 에서 results 변수는 데이터 타입이 bool array 인데 array가 그냥 계속 늘어난다. 결국 foreach (bool isDeviceConnected in results) isAllDeviceConnected &= isDeviceConnected; 이 구문에서 원하는대로 동작하지 않는다. 전체 디바이스를 검색하는 것이 아니라 여태까지 검사했던 모든 디바이스 검사하게 된다. 즉 디바이스 검사 결과를 저장하고 다시 가져다 이전 결과와 현재 결과를 종합해서 검사하고 있는 꼴이다.

해결책은 new Thread가 무한루프에 갇히게 해서는 안된다. 타이머를 쓰든 다른 event를 만들든 해서 CheckConnection method를 호출해야한다.

private Communication()
{
    Log = Logger.Instance;
    LD = MobileRobotController.Instance;
    MPlus = MPlusController.Instance;
 
    StartCommunication();
}
 
private void StartCommunication()
{
    CheckConnection();
}
 
public bool isCommunicateDone = true;
public bool isAllDeviceConnected = true;   // The result of all object connection
 
// Check each object connection by async await
private async Task CheckConnection()
{
    while (isCommunicateDone)
    {
        List<Task<bool>> tasks = new List<Task<bool>>();
        isAllDeviceConnected = true;
 
 
        // Process checking connection by thread
        foreach (TaskList obj in Enum.GetValues(typeof(TaskList)))
        {
            tasks.Add(Task.Run(() => DeviceConnection(obj)));
        }
 
        // Waiting all thread
        var results = await Task.WhenAll(tasks);
 
        // Check all device connection
        foreach (bool isDeviceConnected in results) isAllDeviceConnected &= isDeviceConnected;
 
        await Task.Delay(10);
    }
}
 
private bool DeviceConnection(TaskList Device)
{
     ...........................
}