0

我有一个启动两个线程的主程序。首先，我只有这个线程，它在 while(true) 内执行以下操作：

loopCounter++;              
outputStream.write(pollBuf);
readResponse();
Thread.sleep(200);
outputStream.write(statusBuf);
readResponse();
logger.info("status executed");

问题是，当第二个 readResponse 没有返回时，因为监听 comport 的设备根本没有回答我被卡住了，并且给出机器状态的显示器仍然显示“正在运行”而不是软件错误或其他东西一样。所以我需要知道这个线程何时被卡住，因此我添加了另一个线程，该线程现在在另一个线程之前在主程序中创建和启动，第二个线程的 run() 方法的 while(true) 内的代码：

public class StatusThread implements Runnable {
  static Logger logger = Logger.getLogger(StatusThread.class);

  private Nv10ToVcdm mainProgram;

  public void initialize(Nv10ToVcdm mProgram, boolean acceptBills) {
    mainProgram = mProgram;
  }

  public void run() {
    int loopCounter = mainProgram.getLoopCounter();
    while (true) {
      try {
        Thread.sleep(1000);
        int currentLoopCounter = mainProgram.getLoopCounter();
        if (loopCounter != currentLoopCounter) {
          loopCounter = currentLoopCounter;
        } else {
          mainProgram.writeToDisplay("SOFTWARE", "ERROR");
        }
      } catch (InterruptedException ie) {
        logger.error("Interrupted exception: " + ie.getMessage());
        mainProgram.errorOnDisplay();
      }
    }
  }
}

可悲的是，第一个线程被卡在侦听 comport 上并没有释放它在 cpu 上的声明，因此第二个线程没有得到任何 CPU 时间。那么：当监听 com 端口的线程挂起时，如何在显示屏上显示错误？

挂起的 readResponse 方法，afaik 它挂在“byte firstByte = (byte) inputStream.read();”上 因为没有什么可读的：

private void readResponse() {
    byte[] bufferLeft = new byte[4];
    byte[] bufferRight = new byte[2];
    byte size = 0;
    boolean responseFound = false;

    try {
      while(!responseFound) {
        byte firstByte = (byte) inputStream.read();
        if (firstByte == -1) {
          logger.error("first byte of response is -1");
          mainProgram.errorOnDisplay();
          break;
        }
        for (int i = 0; i < 4; i++) {
          bufferLeft[i] = (byte) inputStream.read();
        }
        size = bufferLeft[0];
        if (size > 0) {
          bufferRight =  new byte[size];
          int i2 = 0;
          while (i2 < size) {
            bufferRight[i2] = (byte) inputStream.read();
            i2++;
          }
        }

        if (firstByte == 1 && bufferLeft[1] == 40) {
          responseFound = true;
        }
      }

      if (size == 11) {
        // some code
      }
    } catch(IOException ioe) {
      logger.error("IO Exception in readResponse: " + ioe.getMessage());
      mainProgram.errorOnDisplay();
    }
}

编辑（为第二个线程和 readResponse 方法添加了完整代码）

输入流初始化如下：

serialPort = (SerialPort) commPort;
serialPort.setSerialPortParams(9600, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
inputStream = serialPort.getInputStream();
4

1 回答 1

1

您是否尝试在阅读前检查数据可用性？

就像是：

if (inputStream.available() > 0) {
  // do your read
} else {
  // wait for some time and retry or trow an error
}
于 2013-11-05T15:00:47.087 回答