Multithreading et ports série

Question

Ok..ce sera long mais je dois d'abord expliquer quelques notions de base.

Cette partie de mon logiciel est destinée à trier des articles qui descendent d'une bande transporteuse. J'utilise Modbus pour la bande transporteuse. Modbus ouvrira les portes à une heure précise pour laisser passer un objet à travers la porte. Les articles passeront par certaines portes en fonction du poids.

Je surveille un capteur pour déterminer quand un article est sur une balance. Lorsque le capteur est bloqué, l'article est pesé et envoyé à la porte appropriée. Les minuteries sont réglées pour ouvrir/fermer la porte.

Mon code fonctionnera pour ceci..le problème est, il ne fonctionnera pas pour plusieurs articles. Je veux dire par là qu'une porte est ouverte, le détecteur n'est pas surveillé tant que la porte n'est pas fermée. Donc, pendant que l'article A est sur le chemin de la porte, l'article B ne sera pas pesé sur l'échelle quand il bloque le capteur. Je pourrais avoir jusqu'à 8 articles sur la ligne à la fois. Voici le code que je suis maintenant en cours d'exécution:

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 
    } 
    } 

Ce code fonctionne très bien, je dois juste être en mesure de rendre compte de plusieurs éléments sur la ligne. Des suggestions ????

J'ai aussi essayé les éléments suivants:

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(); 
} 

Quand je l'ai fait, j'ai commencé les deux fils lorsque le bouton de démarrage a été pressé. Je reçois toutes sortes d'exceptions et le programme finit par lancer SEHException et se bloque. Les autres erreurs que je reçois disent "Port série déjà ouvert" ou "Erreur E/S".

Answer 1

Je suggère que votre meilleur pari est probablement de créer un fil dédié à s'asseoir sur chaque port série. Une telle approche n'exigera ni n'interdira aucune similitude dans la façon dont les ports sont traités, évitera toute interférence dans le fonctionnement entre les ports, et sera évolutive dans des limites raisonnables (l'utilisation d'un thread pour chacun des 32 ports serait bien; un fil pour chacun de 1000 serait mauvais). Bien qu'il faille éviter de créer des threads qui s'exécuteront brièvement et s'arrêteront, ou créer un très grand nombre de threads, l'utilisation d'un thread dédié pour chaque port série garantira que le thread sera prêt à gérer les données.

Answer 2

Je remarque que vous n'avez aucune boucle dans les méthodes DoWork de votre thread. Ce serait un bon endroit pour commencer. Le thread de travail doit être une boucle qui ne retourne pas jusqu'à ce que CancellationPending soit défini sur true. Ils ne se boucleront pas d'eux-mêmes parce que vous les avez dans un thread - le thread s'exécutera jusqu'à ce que ce soit fait, puis quittera.

Édité pour ajouter: Ce que vous semblez manquer, c'est que vous devez diviser le code qui surveille l'échelle et le code qui ouvre et ferme la porte. Une façon de le faire serait d'avoir une boucle infinie qui surveille l'échelle, et quand il détecte quelque chose, il commence un nouveau thread qui gère l'ouverture et la fermeture de la porte.

Answer 3

Je pense que vous avez besoin de quelque chose comme ça. Je ne sais pas si les verrous sont nécessaires, mais je les ai ajouté pour la sécurité puisque vous obtenez des erreurs

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 
     } 
     } 
    }