C # 비동기 작업이 완료되기 전에 완료 됨

웹 소켓에서 데이터를 수신하고 수정 한 다음 데이터 서비스에 업로드하는 네트워크 애플리케이션을 개발 중입니다. 데이터를 업로드하는 데 약간의 시간이 걸리며 한 번에 여러 메시지를 업로드하여 지연 시간을 숨기고 싶습니다. 업로드가 완료되면 웹 소켓을 통해 승인을 다시 보내야합니다.

나는 모든 미해결 작업을 보관하기 위해 작업 대기열을 만들었습니다. 이것은 잘 작동하는 것 같아서 포함하지 않았습니다. 하지만 내 업로드 작업이 실제로 완료되기 전에 완료되는 것 같습니다. 다음은 잘린 샘플입니다.

private async Task UploadDataAsync(string data, CancellationToken cancellationToken)
{
    Task uploadTask = new Task(async () =>
    {
        // Simulates uploading data
        await Task.Delay(5000, cancellationToken);
    });

    _ = uploadTask.ContinueWith(async (t1) =>
    {
        // Clean up the task
        await RemoveTask(t1);

        if (t1.IsCompletedSuccessfully)
            await SendAck(this, data, cancellationToken);
        else if (t1.IsFaulted)
            logger.LogError(t1.Exception, $"An error occurred while uploading {data}");
        else if (t1.IsCanceled)
            logger.LogWarning($"An upload task {data} was canceled");

    }, TaskScheduler.Default);

    await AddTask(uploadTask);
    uploadTask.Start();
}

앞의 코드에서는 데이터가 업로드되기 전에 승인이 전송됩니다. 놀랍게도 이것은 내 작업이 비동기 람다를 사용하기 때문인 것 같습니다. 이유 때문에 uploadTask업로드가 기다리고있을 때 완료되는 것을 이해하지 못합니다 . 그래서 다음과 같이 변경했습니다.

private async Task UploadDataAsync(string data, CancellationToken cancellationToken)
{
    Task uploadTask = new Task(() =>
    {
        // Simulates uploading data
        Task.Delay(5000, cancellationToken).Wait();
    });

    _ = uploadTask.ContinueWith((t1) =>
    {
        // Clean up the task
        RemoveTask(t1).Wait();

        if (t1.IsCompletedSuccessfully)
            SendAck(this, data, cancellationToken).Wait();
        else if (t1.IsFaulted)
            logger.LogError(t1.Exception, $"An error occurred while uploading {data}");
        else if (t1.IsCanceled)
            logger.LogWarning($"An upload task {data} was canceled");

    }, TaskScheduler.Default);

    await AddTask(uploadTask);
    uploadTask.Start();
}

이제 일이 잘못되거나 작업이 취소 된 경우 (예 : 서버가 종료 됨)를 제외하고 모든 것이 올바른 순서로 실행됩니다. 이제 AggregateExceptions 및 TaskCanceledExceptions를 처리하고 있습니다.

이것은 내가 만드는 것보다 쉬울 것 같습니다. 내가 잘못하고 있니?

편집UploadDataAsync 컨텍스트 를 호출 하는 의사 코드 추가 .

protected override async Task DoConnection(CancellationToken cancellationToken)
{
    while (_websocket.State == WebSocketState.Open && !cancellationToken.IsCancellationRequested)
    {
        // Simulates getting websocket data
        string result = await _websocket.ReceiveAsync();

        // This should only asynchronously wait for the upload task to get
        // created. It should not wait for the upload to complete.
        await OnDataReceived(result, cancellationToken);
    }
}