Đa luồng và Cổng nối tiếp

Question

Ok .. điều này sẽ kéo dài nhưng tôi cần giải thích một số nền trước.

Phần này của phần mềm của tôi là để sắp xếp các mục chạy xuống băng tải. Tôi đang sử dụng Modbus cho băng tải. Modbus sẽ mở các cổng tại một thời điểm cụ thể để cho một mục đi qua cổng. Vật phẩm sẽ đi qua một số cổng dựa trên trọng lượng.

Tôi đang theo dõi một cảm biến để xác định thời điểm một mục trên thang đo. Khi cảm biến bị chặn, vật phẩm được cân và gửi đến cổng thích hợp. Bộ hẹn giờ được đặt để mở/đóng cổng.

Mã của tôi sẽ hoạt động cho vấn đề này..có vấn đề, nó sẽ không hoạt động đối với nhiều mục. Bởi vì tôi có nghĩa là, trong khi một cổng được mở, cảm biến không được giám sát cho đến khi cổng được đóng lại. Vì vậy, trong khi mục A đang trên đường đến cổng, mục B sẽ không bị cân nặng trên quy mô khi nó chặn cảm biến. Tôi có thể có tối đa 8 mục trên cùng một lúc. Đây là mã tôi đang chạy ngay bây giờ:

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

Mã này hoạt động tốt, tôi chỉ cần có thể tính đến nhiều mục trên dòng. Mọi đề xuất ????

Tôi cũng đã thử như sau:

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

Khi tôi đã làm điều này, tôi bắt đầu cả hai đề khi nút bắt đầu được nhấn. Tôi nhận được tất cả các loại ngoại lệ và chương trình cuối cùng ném SEHException và treo. Các lỗi khác tôi nhận được nói "Cổng nối tiếp đã được mở" hoặc "Lỗi I/O".

Answer 1

Tôi khuyên bạn nên đặt cược tốt nhất có thể là tạo một chuỗi chuyên dụng để ngồi trên mỗi cổng nối tiếp. Cách tiếp cận như vậy sẽ không yêu cầu, cũng không cấm, bất kỳ sự tương đồng nào về cách xử lý các cổng, sẽ tránh bất kỳ sự can thiệp nào giữa các cổng và sẽ có thể mở rộng trong giới hạn hợp lý (sử dụng một chuỗi cho 32 cổng); một chủ đề cho mỗi 1.000 sẽ là xấu). Mặc dù chúng ta nên tránh tạo các luồng chỉ đơn giản là chạy trong một thời gian ngắn và thoát, hoặc tạo một số lượng lớn các luồng, sử dụng một chuỗi chuyên dụng cho mỗi cổng nối tiếp sẽ đảm bảo rằng khi dữ liệu đến trong đó sẽ có một luồng sẵn sàng để xử lý nó.

Answer 2

Tôi nhận thấy rằng bạn không có bất kỳ vòng lặp nào trong các phương pháp DoWork của luồng. Đó sẽ là một nơi tuyệt vời để bắt đầu. Chuỗi công nhân phải là một vòng lặp không trả lại cho đến khi CancellationPending được đặt thành true. Chúng sẽ không tự lặp lại chỉ bởi vì bạn có nó trong một luồng - luồng sẽ chạy cho đến khi nó được thực hiện, sau đó thoát ra.

Đã chỉnh sửa để thêm: Những gì bạn dường như bị thiếu là bạn cần chia nhỏ mã theo dõi tỷ lệ và mã mở và đóng cổng. Một cách để làm điều đó sẽ là có một vòng lặp vô hạn để theo dõi quy mô, và khi nó phát hiện ra thứ gì đó, nó bắt đầu một luồng mới xử lý việc mở và đóng cửa.

Answer 3

Tôi nghĩ bạn cần một cái gì đó như thế này. Không biết liệu ổ khóa có cần thiết hay không nhưng tôi đã thêm chúng cho an toàn vì bạn đang gặp lỗi

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