समानांतर धागा परीक्षण

डीबगर में, आप सही बिंदु पर निष्पादन प्रवाह को आसानी से पकड़ सकते हैं, और फिर, विश्लेषण के बाद, इसे पुनरारंभ करें। स्वचालित परीक्षणों में, ये ऑपरेशन पागलपन से जटिल दिखते हैं।

और आपको इसकी आवश्यकता क्यों है?

समानांतर सिस्टम बनाना सबसे आसान काम नहीं है। समानता और समकालिकता के बीच संतुलन बनाए रखना चाहिए। यदि आप सिंक्रनाइज़ नहीं करते हैं, तो आप स्थिरता खो देंगे। यदि आप पुन: सिंक्रनाइज़ करते हैं, तो आपको एक सुसंगत प्रणाली मिलती है।

रीफैक्टरिंग आम तौर पर एक माइनफील्ड के माध्यम से चलना है।

यदि कार्यान्वयन की जटिलता के लिए नहीं, तो स्वचालित परीक्षण बहुत मदद कर सकता है। मेरी राय में, एक समानांतर प्रणाली में, कोड के अलग-अलग परस्पर विरोधी अनुभागों के स्वचालित संचालन की जांच करना अच्छा होगा - तथ्य और निष्पादन आदेश।

इसलिए मैं आखिरकार धागे के निलंबन और फिर से शुरू हो गया। जैसा कि पहले ही उल्लेख किया गया है, ऐसा गैर-स्वचालित तंत्र मौजूद है। ये ब्रेकपॉइंट हैं। हम एक नई शब्दावली का आविष्कार नहीं करेंगे - ब्रेकपॉइंट, फिर ब्रेकपॉइंट।

public class Breakpoint { [Conditional("DEBUG")] public static void Define(string name){…} } public class BreakCtrl : IDisposable { public string Name { get; private set; } public BreakCtrl(string name) {…} public BreakCtrl From(params Thread[] threads) {…} public void Dispose(){…} public void Run(Thread thread){…} public void Wait(Thread thread){…} public bool IsCapture(Thread thread){…} public Thread AnyCapture(){…} } 

स्वचालित ब्रेकपॉइंट के गुण:

1. वे केवल डिबग मोड में काम करते हैं (एक विशिष्ट मैक्रो DEBUG के साथ)। हमें यह नहीं सोचना चाहिए कि अतिरिक्त कोड अंतिम उपयोगकर्ता पर सिस्टम के संचालन को प्रभावित करेगा।
2. ब्रेकपॉइंट केवल तभी काम करता है जब इसका नियंत्रक परिभाषित किया गया हो। किसी विशेष परीक्षण में अनावश्यक ब्रेकपॉइंट को सिस्टम का नेतृत्व नहीं करना चाहिए (और परीक्षणों को जटिल करना)।
3. नियंत्रक जानता है कि ब्रेकपॉइंट किस स्थिति में है - क्या यह धारा को पकड़ता है।
4. नियंत्रक ब्रेकपॉइंट को स्ट्रीम जारी करने के लिए बाध्य करने में सक्षम है।
5. और एक विशिष्ट धागे के लिए वैकल्पिक बाध्यकारी। हम एक विशिष्ट प्रवाह को नियंत्रित करना चाहते हैं, हम हर किसी को एक बार चाहते हैं।

 [TestMethod] public void StopStartThreadsTest_exemple1() { var log = new List<string>(); ThreadStart act1 = () => { Breakpoint.Define("empty"); Breakpoint.Define("start1"); log.Add("after start1"); Breakpoint.Define("step act1"); log.Add("after step act1"); Breakpoint.Define("finish1"); }; ThreadStart act2 = () => { Breakpoint.Define("start2"); log.Add("after start2"); Breakpoint.Define("step act2"); log.Add("after step act2"); Breakpoint.Define("finish2"); }; using (var start1 = new BreakCtrl("start1")) using (var step_act1 = new BreakCtrl("step act1")) using (var finish1 = new BreakCtrl("finish1")) using (var start2 = new BreakCtrl("start2")) using (var step_act2 = new BreakCtrl("step act2")) using (var finish2 = new BreakCtrl("finish2")) { var thr1 = new Thread(act1); thr1.Start(); var thr2 = new Thread(act2); thr2.Start(); start1.Wait(thr1); start2.Wait(thr2); start1.Run(thr1); step_act1.Wait(thr1); step_act1.Run(thr1); finish1.Wait(thr1); start2.Run(thr2); step_act2.Wait(thr2); step_act2.Run(thr2); finish2.Wait(thr2); finish1.Run(thr1); finish2.Run(thr2); thr1.Join(); thr2.Join(); } Assert.AreEqual(4, log.Count); Assert.AreEqual("after start1", log[0]); Assert.AreEqual("after step act1", log[1]); Assert.AreEqual("after start2", log[2]); Assert.AreEqual("after step act2", log[3]); } 

वास्तव में असहज? लेकिन आपको इसके साथ रखना होगा - आखिरकार, परीक्षण के बिना रिफैक्टरिंग संभव नहीं है। आपको हमेशा अपने आप से पहले जाना होगा ... ब्ला ब्ला ब्ला। यहां तक ​​कि मुझे जल्द ही पता चला कि इसका उपयोग करना असंभव था। मैं दूसरे दस लिखित परीक्षणों के क्षेत्र में समझ गया। टेस्ट प्रिय और जटिल हैं। लेकिन ...

मुश्किल तो अच्छी है। आखिरकार, मैं जटिलता को सुलझाने के अलावा कुछ नहीं कर सकता। थोड़े प्रयास से हमें यह समाधान मिला:

 public class ThreadTestManager { public ThreadTestManager(TimeSpan timeout, params Action[] threads){…} public void Run(params BreakMark[] breaks){…} } public class BreakMark { public string Name { get; private set; } public Action ThreadActor { get; private set; } public bool Timeout { get; set; } public BreakMark(string breakName){…} public BreakMark(Action threadActor, string breakName){…} public static implicit operator BreakMark(string breakName){…} } 

इसका उपयोग करते समय, पिछला परीक्षण इस तरह दिखेगा:

 [TestMethod] public void StopStartThreadsTest_exemple2() { var log = new List<string>(); Action act1 = () => { Breakpoint.Define("before start1"); Breakpoint.Define("start1"); log.Add("after start1"); Breakpoint.Define("step act1"); log.Add("after step act1"); Breakpoint.Define("finish1"); }; Action act2 = () => { Breakpoint.Define("before start2"); Breakpoint.Define("start2"); log.Add("after start2"); Breakpoint.Define("step act2"); log.Add("after step act2"); Breakpoint.Define("finish2"); }; new ThreadTestManager(TimeSpan.FromSeconds(1), act1, act2).Run( "before start1", "before start2", "start1", "step act1", "finish1", "start2", "step act2", "finish2"); Assert.AreEqual(4, log.Count); Assert.AreEqual("after start1", log[0]); Assert.AreEqual("after step act1", log[1]); Assert.AreEqual("after start2", log[2]); Assert.AreEqual("after step act2", log[3]); } 

प्रबंधक गुण:

1. सभी प्रतिनिधियों को उनके धागे में स्टार्टअप पर लॉन्च किया गया है।
2. ब्रेकपॉइंट मार्कर काम को फिर से शुरू करने का तरीका निर्धारित करते हैं। प्रवेश द्वार नहीं, लेकिन ब्रेकप्वाइंट से बाहर निकलें। शायद यह केवल ब्रेकपॉइंट अमूर्तता को लागू करने की लागत है। लेकिन एक संपत्ति है और इसके बारे में याद रखना कभी-कभी आवश्यक होता है।
3. इसी ब्रेकपॉइंट मार्कर के लिए सभी नियंत्रक डिस्पैचर के काम के दौरान परिभाषित किए गए हैं।
4. ब्रेकप्वाइंट मार्कर के साथ, आप थ्रेड (प्रतिनिधि) निर्दिष्ट कर सकते हैं जिसके साथ यह काम करेगा। डिफ़ॉल्ट रूप से यह सभी के साथ काम करता है।
   
   

    [TestMethod] public void ThreadMarkBreakpointTest_exemple3() { var log = new List<string>(); Action<string> act = name => { Breakpoint.Define("start"); log.Add(name); Breakpoint.Define("finish"); }; Action act0 = () => act("act0"); Action act1 = () => act("act1"); new ThreadTestManager(TimeSpan.FromSeconds(1), act0, act1).Run( new BreakMark(act0, "finish"), new BreakMark(act1, "start"), new BreakMark(act1, "finish")); Assert.AreEqual(2, log.Count); Assert.AreEqual("act0", log[0]); Assert.AreEqual("act1", log[1]); } 

5. परिभाषित समय जिसके दौरान सभी ऑपरेशन किए जाने चाहिए - टाइमआउट। जब पार हो जाता है - सभी धागे मोटे तौर पर और बेरहम (गर्भपात) बंद हो जाते हैं।
6. ब्रेकपॉइंट मार्कर के लिए, आप अप्राप्यता का संकेत जोड़ सकते हैं, यदि आप यहां नहीं मिलते हैं, तो सिस्टम टाइमआउट पर बाहर निकल जाएगा। ब्रेकपॉइंट को ट्रिगर करने से परीक्षण में विफलता होगी। इस तंत्र का उपयोग अवरुद्ध के तथ्य को सत्यापित करने के लिए किया जाता है।
   
   

    [TestMethod] public void Timeout_exemple4() { var log = new List<string>(); Action act = () => { try { while (true) ; } catch (ThreadAbortException) { log.Add("timeout"); } Breakpoint.Define("don't work"); }; new ThreadTestManager(TimeSpan.FromSeconds(1), act).Run( new BreakMark("don't work") { Timeout = true }); Assert.AreEqual("timeout", log.Single()); } 

7. यदि आप प्रवाह को रोकना चाहते हैं और जारी नहीं रखना चाहते हैं, तो आपको टाइमआउट के साथ मार्कर के बाद उपयुक्त ब्रेकपॉइंट मार्कर निर्दिष्ट करना होगा।
   
   

    [TestMethod] public void CatchThread_exemple5() { var log = new List<string>(); Action act0 = () => { bool a = true; while (a) ; Breakpoint.Define("act0"); }; Action act1 = () => { Breakpoint.Define("act1"); log.Add("after act1"); }; new ThreadTestManager(TimeSpan.FromSeconds(1), act0, act1).Run( new BreakMark("act0") { Timeout = true }, "act1"); Assert.IsFalse(log.Any()); } 

पुनश्च: समाधान