Cách xử lý luồng bộ nhớ trong tác vụ?

Question

Tôi đã phương pháp sau

public void Write() { 
    var tasks = new List<Task>(); 
    while(...) { 
     var memoryStream = new MemoryStream(...); 
     var task = _pageBlob.WritePagesAsync(memoryStream, ...); 
     tasks.Add(task); 
    }  
    Task.WaitAll(tasks.ToArray()); 
} 

Làm thế nào để xử lý một cách chính xác memoryStream rằng trong Task? Tôi cần phải xử lý đối tượng memoryStream khi tác vụ hoàn tất.

Answer 1

Spl nó ra cơ thể while vòng lặp của bạn thành một phương pháp riêng biệt async:

private async Task WriteAsync(...) 
{ 
    using (var memoryStream = new MemoryStream(...)) 
    { 
    await _pageBlob.WritePagesAsync(memoryStream, ...); 
    } 
} 

Sau đó, sử dụng phương pháp mới của bạn:

public void Write() { 
    var tasks = new List<Task>(); 
    while(...) { 
    tasks.Add(WriteAsync(...)); 
    }  
    Task.WaitAll(tasks.ToArray()); 
} 

Trên một mặt lưu ý, ngăn chặn trên mã không đồng bộ (Task.WaitAll) không phải là nói chung là một ý tưởng tốt . Một cách tiếp cận tự nhiên hơn là giữ cho nó không đồng bộ:

public async Task WriteAsync() { 
    var tasks = new List<Task>(); 
    while(...) { 
    tasks.Add(WriteAsync(...)); 
    }  
    await Task.WhenAll(tasks); 
} 

Answer 2

Bạn có hai lựa chọn:

1-đóng gói tất cả các quá trình bên trong một nhiệm vụ:

while(...) { 

    var task = Task.Run(async() => { 

     var memoryStream = new MemoryStream(...); 
     var res = await _pageBlob.WritePagesAsync(memoryStream, ...); 
     memoryStream.Dispose(); 

    }); 

    tasks.Add(task); 
}  

2-Sử dụng một Tiếp tục:

while(...) { 
    var memoryStream = new MemoryStream(...); 
    var task = _pageBlob.WritePagesAsync(memoryStream, ...) 
       .ContinueWith((PrevTask) => memoryStream.Dispose()); 

    tasks.Add(task); 
}  

Answer 3

tôi sẽ làm một cái gì đó như thế này:

public void Write() 
{ 
    var tasks = new List<Task>(); 
    while (...) 
    { 
     var memoryStream = new MemoryStream(...); 
     var task = WritePagesAsync(memoryStream, ...); 
     tasks.Add(task); 
    } 
    Task.WaitAll(tasks.ToArray()); 
} 

private async Task WritePagesAsync(MemoryStream memoryStrem, ...) 
{ 
    await _pageBlob.WritePagesAsync(memoryStrem); 
    memoryStrem.Dispose(); 
}