多线程和串口

Question

好的..这将是漫长的，但我需要先解释一些背景。

我的这部分软件是分类顺着传送带上的物品。 我使用Modbus作为传送带。 Modbus将在特定时间打开门，让物品通过门。项目将根据体重通过某些门。

我监测的传感器，以确定何时产品的规模。当传感器被阻塞时，物品被称重并被发送到适当的门。定时器设置为打开/关闭门。

我的代码会为this..the问题的工作是，它不会为多个项目工作。我的意思是，当门打开时，传感器在门关闭之前不被监控。因此，当物品A在通往大门的路上时，物品B在阻塞传感器时不会在秤上称重。一次最多可以有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方法没有任何循环。那将是一个开始的好地方。工作线程应该是一个循环，直到CancellationPending设置为true才会返回。它们不会因为它在一个线程中而自行循环 - 线程会一直运行直到完成，然后退出。

编辑补充：你似乎什么是失踪的是，你需要分割，监控规模的代码，并打开和关闭门的代码。要做到这一点的一种方法是有一个无限循环来监视比例，当它检测到某个东西时，它会启动一个处理打开和关闭门的新线程。

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