TPL Dataflow, sự khác biệt chức năng giữa Post() và SendAsync() là gì?

Question

Tôi nhầm lẫn về sự khác biệt giữa việc gửi các mục qua Post() hoặc SendAsync(). Sự hiểu biết của tôi là trong mọi trường hợp khi một mục đạt đến bộ đệm đầu vào của một khối dữ liệu, điều khiển được trả về ngữ cảnh gọi, đúng không? Vậy tại sao tôi lại cần SendAsync? Nếu giả định của tôi là không đúng thì tôi tự hỏi, ngược lại, tại sao bất cứ ai sẽ sử dụng Post() nếu toàn bộ ý tưởng sử dụng các khối dữ liệu là thiết lập một môi trường đồng thời và không đồng bộ.

Tôi hiểu tất nhiên sự khác biệt về mặt kỹ thuật trong bài viết đó() trả về một bool trong khi SendAsync trả về một nhiệm vụ đang chờ của bool. Nhưng những gì có ý nghĩa gì? Khi nào sự trở lại của một bool (mà tôi hiểu là một xác nhận cho dù mục đã được đặt trong hàng đợi của khối dữ liệu hay không) bao giờ bị trì hoãn? Tôi hiểu ý tưởng chung của khung công tác đồng bộ async/await nhưng ở đây nó không có ý nghĩa gì cả bởi vì khác với bool kết quả của bất kỳ thứ gì được thực hiện cho mục được chuyển vào không bao giờ được trả về người gọi mà thay vào đó được đặt trong "out-queue" và được chuyển tiếp đến các khối dữ liệu được liên kết hoặc bị loại bỏ.

Và có sự khác biệt về hiệu suất giữa hai phương pháp khi gửi các mục không?

Answer 1

Để thấy sự khác biệt, bạn cần một tình huống trong đó các khối sẽ hoãn thông báo của họ. Trong trường hợp này, Post sẽ trả lại false ngay lập tức, trong khi SendAsync sẽ trả lại một Task sẽ được hoàn thành khi khối quyết định việc cần làm với thư. Task sẽ có kết quả true nếu thông báo được chấp nhận và kết quả là false nếu không.

Một ví dụ về tình huống trì hoãn là tham gia không tham lam.Một ví dụ đơn giản hơn là khi bạn đặt BoundedCapacity:

[TestMethod] 
public void Post_WhenNotFull_ReturnsTrue() 
{ 
    var block = new BufferBlock<int>(new DataflowBlockOptions {BoundedCapacity = 1}); 

    var result = block.Post(13); 

    Assert.IsTrue(result); 
} 

[TestMethod] 
public void Post_WhenFull_ReturnsFalse() 
{ 
    var block = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 1 }); 
    block.Post(13); 

    var result = block.Post(13); 

    Assert.IsFalse(result); 
} 

[TestMethod] 
public void SendAsync_WhenNotFull_ReturnsCompleteTask() 
{ 
    // This is an implementation detail; technically, SendAsync could return a task that would complete "quickly" instead of already being completed. 
    var block = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 1 }); 

    var result = block.SendAsync(13); 

    Assert.IsTrue(result.IsCompleted); 
} 

[TestMethod] 
public void SendAsync_WhenFull_ReturnsIncompleteTask() 
{ 
    var block = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 1 }); 
    block.Post(13); 

    var result = block.SendAsync(13); 

    Assert.IsFalse(result.IsCompleted); 
} 

[TestMethod] 
public async Task SendAsync_BecomesNotFull_CompletesTaskWithTrueResult() 
{ 
    var block = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 1 }); 
    block.Post(13); 
    var task = block.SendAsync(13); 

    block.Receive(); 

    var result = await task; 
    Assert.IsTrue(result); 
} 

[TestMethod] 
public async Task SendAsync_BecomesDecliningPermanently_CompletesTaskWithFalseResult() 
{ 
    var block = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 1 }); 
    block.Post(13); 
    var task = block.SendAsync(13); 

    block.Complete(); 

    var result = await task; 
    Assert.IsFalse(result); 
} 

Answer 2

Tài liệu làm cho IMO rõ ràng, hợp lý. Cụ thể, đối với Post:

Phương pháp này sẽ trở lại khi khối mục tiêu quyết định chấp nhận hoặc từ chối mục, nhưng không chờ cho mục đó thực sự được xử lý.

Và:

Đối với khối mục tiêu hỗ trợ hoãn thông điệp đưa ra, hoặc cho các khối có thể làm chế biến hơn trong việc thực hiện Post của họ, xem xét sử dụng SendAsync, mà sẽ trở lại ngay lập tức và sẽ cho phép các mục tiêu trì hoãn thông báo đã đăng và sau đó tiêu thụ nó sau khi trả về SendAsync.

Nói cách khác, trong khi cả hai đều không đồng bộ đối với chế biến thông điệp với, SendAsync cho phép khối mục tiêu để quyết định có hay không để chấp nhận thông điệp không đồng bộ quá.

Nghe có vẻ như SendAsync là phương pháp "không đồng bộ" thường xuyên hơn và có thể được khuyến khích nói chung. Những gì không phải là rõ ràng với tôi là lý do tại sao cả hai đều được yêu cầu, vì nó chắc chắn có vẻ như Post là tương đương rộng rãi khi sử dụng SendAsync và sau đó chỉ cần chờ kết quả.