मल्टीथ्रेडिंग और सीरियल पोर्ट

Question

ठीक है..यह लंबा होगा लेकिन मुझे पहले कुछ पृष्ठभूमि की व्याख्या करने की आवश्यकता है।

मेरे सॉफ़्टवेयर का यह हिस्सा कन्वेयर बेल्ट को चलाने वाली वस्तुओं को सॉर्ट करने के लिए है। मैं कन्वेयर बेल्ट के लिए मॉडबस का उपयोग कर रहा हूं। एक आइटम गेट के माध्यम से जाने के लिए मॉडबस एक विशिष्ट समय पर द्वार खोल देगा। वजन के आधार पर आइटम कुछ गेट्स के माध्यम से जायेंगे।

मैं एक सेंसर की निगरानी कर रहा हूं यह निर्धारित करने के लिए कि कोई आइटम स्केल पर कब होता है। जब सेंसर अवरुद्ध हो जाता है, तो आइटम का वजन होता है और उचित द्वार पर भेजा जाता है। टाइमर गेट को खोलने/बंद करने के लिए सेट हैं।

मेरा कोड इसके लिए काम करेगा .. समस्या यह है कि यह कई वस्तुओं के लिए काम नहीं करेगा। इसका मतलब है, जबकि एक गेट खुला है, गेट बंद होने तक सेंसर की निगरानी नहीं की जा रही है। इसलिए जब आइटम ए गेट के रास्ते पर है, तो आइटम बी को सेंसर को अवरुद्ध करते समय स्केल पर वजन नहीं मिलेगा। मेरे पास लाइन पर 8 आइटम तक एक बार हो सकता है।

private void SensorThread_DoWork(object sender, DoWorkEventArgs e) 
{ 
    if (SensorThread.CancellationPending == true) 
     e.Cancel = true; 
    else 
    { 
     ReadSensor(); 
    }  
} 

private void SensorThread_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) 
{ 
    //if sensor is blocked 
    if (sensorstatus == 0) 
    { 
     //the timers just start the thread 
     scaleTimer.Start(); 
    } 
    else 
    { 
     sensorTimer.Start(); 
    } 
} 

private void ScaleThread_DoWork(object sender, DoWorkEventArgs e) 
{ 
    if (ScaleThread.CancellationPending == true) 
    { 
     e.Cancel = true; 
    } 
    else 
    { 
     ReadScale(); 
     //SaveWeight(); 
     prevgate = gate; 
     gate = DetermineGate(); 
     SetOpenDelay(); 
     SetDuration(); 
    } 
    } 

private void ScaleThread_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) 
{ 
    //if gate = 0, this means the weight of meat on scale 
    //is not in any weight range. Meat runs off the end. 
    if (gate == 0) 
    { 
     txtStatus.Invoke(new UpdateStatusCallback(UpdateStatus), new object[] { meatweight.ToString() + 
                       "lbs is out of range"}); 
     sensorTimer.Start(); 
    } 
    else 
    { 
     //open gate 
     //then close gate 
    } 
    } 

इस कोड को ठीक काम करता है, मैं सिर्फ लाइन पर कई आइटम प्राप्त करने में सक्षम होने की जरूरत है: यहाँ कोड मैं अब चल रहा हूँ। कोई सुझाव ????

private void SensorThread_DoWork(object sender, DoWorkEventArgs e) 
{ 
    if (SensorThread.CancellationPending == true) 
     e.Cancel = true; 
    else 
    { 
     ReadSensor(); 
    }  
}  

private void SensorThread_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) 
{ 
    sensorTimer.Start(); 
} 

    private void ScaleThread_DoWork(object sender, DoWorkEventArgs e) 
{ 
    if (ScaleThread.CancellationPending == true) 
    { 
     e.Cancel = true; 
    } 
    else 
    { 
     //sensor blocked 
     if (sensorstatus == 0) 
     { 
      ReadScale(); 
      //SaveWeight(); 
      prevgate = gate; 
      gate = DetermineGate(); 
      SetOpenDelay(); 
      SetDuration(); 

      //if gate = 0, this means the weight of meat on scale 
      //is not in any weight range. Meat runs off the end. 
      if (gate == 0) 
      { 
      txtStatus.Invoke(new UpdateStatusCallback(UpdateStatus), new object[] { meatweight.ToString() + 
                       "lbs is out of range"}); 
      } 
      else 
      { 
      //open gate 
      //close gate 
      } 
    } 
} 

private void ScaleThread_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) 
{ 
    scaleTimer.Start(); 
} 

जब मैं ऐसा किया, मैं दोनों धागे शुरू हुई जब शुरू बटन दबाया गया था:

मैं भी निम्नलिखित की कोशिश की है। मुझे सभी प्रकार के अपवाद मिलते हैं और कार्यक्रम अंततः SEHException और क्रैश फेंकता है। मुझे लगता है कि अन्य त्रुटियां "सीरियल पोर्ट पहले ही खोला गया है" या "I/O त्रुटि"।

Answer 1

मैं सुझाव दूंगा कि आपकी सर्वश्रेष्ठ शर्त शायद प्रत्येक धारावाहिक बंदरगाह पर बैठने के लिए समर्पित धागा तैयार करे। ऐसे दृष्टिकोण को न तो बंदरगाहों के संचालन में किसी भी तरह की समानता की आवश्यकता होगी, न ही मना कर दिया जाएगा, बंदरगाहों के बीच संचालन में हस्तक्षेप से बच जाएगा, और उचित सीमाओं के भीतर स्केलेबल होगा (32 बंदरगाहों में से प्रत्येक के लिए धागा का उपयोग करना ठीक होगा; 1,000 में से प्रत्येक के लिए एक धागा खराब होगा)। हालांकि किसी को थ्रेड बनाने से बचना चाहिए जो कि केवल थोड़े समय के लिए चलाएगा और छोड़ देगा, या प्रत्येक सीरियल पोर्ट के लिए समर्पित थ्रेड का उपयोग करके वास्तव में बड़ी संख्या में थ्रेड बनायेगा, यह सुनिश्चित करेगा कि जब डेटा आता है तो इसे संभालने के लिए तैयार धागा होगा।

Answer 2

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

जोड़ने के लिए संपादित: आप जो खो रहे हैं वह यह है कि आपको उस कोड को विभाजित करने की आवश्यकता है जो स्केल और कोड खोलता है और द्वार को बंद करता है। ऐसा करने का एक तरीका एक अनंत लूप होगा जो स्केल पर नज़र रखता है, और जब यह कुछ पता लगाता है, तो यह एक नया धागा शुरू करता है जो द्वार खोलने और बंद करने को संभालने में सक्षम होता है।

Answer 3

मुझे लगता है कि आपको ऐसा कुछ चाहिए। के बाद से आप त्रुटियों

private void SensorThread_DoWork(object sender, DoWorkEventArgs e) 
{ 
    int sensor = 1; 
    while(!SensorThread.CancellationPending == true) 
    { 
     int newSensor; 
     lock(this) 
     { 
      newSensor = ReadSensor(); 
     } 

     //sensor state changed 
     if(newSensor != sensor) 
     { 
      //sensor was 1 and changed to 0 
      if(newSensor==0) 
      { 
       scaleTimer.Start(); 
      } 
      sensor = newSensor; 
     } 
     Thread.Sleep(1); 
    } 
    e.Cancel = true; 
}  

private void ScaleThread_DoWork(object sender, DoWorkEventArgs e) 
{ 
    //sensor blocked 
    //if (sensorstatus == 0) 
    { 
     lock(this) 
     { 
      ReadScale(); 
     } 
     //SaveWeight(); 
     prevgate = gate; 
     gate = DetermineGate(); 
     lock(this) 
     { 
      SetOpenDelay(); 
      SetDuration(); 
     } 

     //if gate = 0, this means the weight of meat on scale 
     //is not in any weight range. Meat runs off the end. 
     if (gate == 0) 
     { 
     txtStatus.Invoke(new UpdateStatusCallback(UpdateStatus), new object[] { meatweight.ToString() + 
                      "lbs is out of range"}); 
     } 
     else 
     { 
     lock(this) 
     { 
     //open gate 
     } 
     lock(this) 
     { 
     //close gate 
     } 
     } 
    }