टीपीएल डेटाफ्लो, पोस्ट() और SendAsync() के बीच कार्यात्मक अंतर क्या है?

Question

मैं पोस्ट() या SendAsync() के माध्यम से आइटम भेजने के बीच अंतर के बारे में उलझन में हूं। मेरी समझ यह है कि सभी मामलों में एक आइटम एक डेटा ब्लॉक के इनपुट बफर तक पहुंचने के बाद, कॉलिंग संदर्भ में नियंत्रण वापस कर दिया जाता है, सही? तो मुझे कभी भी SendAsync क्यों चाहिए? अगर मेरी धारणा गलत है तो मुझे आश्चर्य है, इसके विपरीत, कोई भी पोस्ट() का उपयोग क्यों करेगा यदि डेटा ब्लॉक का उपयोग करने का पूरा विचार एक समवर्ती और एसिंक पर्यावरण स्थापित करना है।

मैं समझता हूं कि उस पोस्ट में तकनीकी रूप से अंतर() एक बूल देता है जबकि SendAsync बूल का एक प्रतीक्षा योग्य कार्य देता है। लेकिन इसका क्या प्रभाव है? एक बूल की वापसी कब होगी (जो मैं समझता हूं कि यह पुष्टि है कि आइटम को डेटा ब्लॉक की कतार में रखा गया था या नहीं) कभी देरी हो सकती है? मैं async/प्रतीक्षारक समरूपता ढांचे के सामान्य विचार को समझता हूं लेकिन यहां यह पूरी तरह से समझ में नहीं आता है क्योंकि एक बूल के अलावा, पास किए गए आइटम को जो कुछ भी किया जाता है, उसके परिणाम कॉलर को कभी वापस नहीं लौटाए जाते हैं बल्कि इसके बजाय "आउट-कतार" और या तो लिंक किए गए डेटा ब्लॉक या त्याग किए जाने के लिए अग्रेषित किया गया।

और क्या आइटम भेजते समय दो तरीकों के बीच कोई प्रदर्शन अंतर है?

Answer 1

अंतर देखने के लिए, आपको ऐसी स्थिति की आवश्यकता है जहां ब्लॉक उनके संदेशों को स्थगित कर देगा। इस मामले में, Postfalse तुरंत लौटाएगा, जबकि SendAsyncTask लौटाएगा जो ब्लॉक पूरा होने पर संदेश के साथ क्या करना है, पूरा हो जाएगा। Task में true परिणाम होगा यदि संदेश स्वीकार किया गया है, और false परिणाम नहीं है।

स्थगित स्थिति का एक उदाहरण एक लालची शामिल है।एक सरल उदाहरण है जब आप 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

प्रलेखन यह उचित स्पष्ट, आईएमओ बनाता है। विशेष रूप से, Post के लिए:

इस विधि एक बार लक्ष्य ब्लॉक को स्वीकार करने या आइटम अस्वीकार करने के लिए फैसला किया है वापस आ जाएगी, लेकिन जब तक अन्यथा लक्ष्य ब्लॉक के विशेष अर्थ विज्ञान से तय, यह वास्तव में करने के लिए आइटम के लिए इंतजार नहीं कर रहा है प्रोसेस किया गया।

और:

है कि पेशकश संदेशों स्थगित, या ब्लॉक कि उनके Post कार्यान्वयन में अधिक संसाधन ऐसा कर सकते हैं के लिए समर्थन लक्ष्य ब्लॉकों के लिए, SendAsync है, जो तुरंत वापस आ जाएगी उपयोग करने पर विचार करने के लिए और लक्ष्य सक्षम हो जाएगा पोस्ट किए गए संदेश को स्थगित कर दें और बाद में इसे SendAsync रिटर्न के बाद उपभोग करें।

दूसरे शब्दों में, जबकि दोनों प्रसंस्करण संदेश के संबंध में अतुल्यकालिक कर रहे हैं, SendAsync तय करने के लिए किया जाए या नहीं को संदेश स्वीकार एसिंक्रोनस रूप से भी लक्ष्य ब्लॉक अनुमति देता है।

ऐसा लगता है कि SendAsync आमतौर पर "अधिक असीमित" दृष्टिकोण है, और जिसे सामान्य रूप से प्रोत्साहित किया जाता है। मुझे स्पष्ट नहीं है कि दोनों की आवश्यकता क्यों है, क्योंकि यह निश्चित रूप से Post जैसा लगता है SendAsync का उपयोग करने के बराबर है और फिर परिणाम पर प्रतीक्षा कर रहा है।