public void serialEvent(SerialPortEvent event) {
switch (event.getEventType()) {
case SerialPortEvent.BI:
case SerialPortEvent.OE:
case SerialPortEvent.FE:
case SerialPortEvent.PE:
case SerialPortEvent.CD:
case SerialPortEvent.CTS:
case SerialPortEvent.DSR:
case SerialPortEvent.RI:
case SerialPortEvent.OUTPUT_BUFFER_EMPTY:
break;
case SerialPortEvent.DATA_AVAILABLE:
readBuffer1 = new byte[90];
Runnable insert1 = new Runnable(){
public void run(){
synchronized (queue) {
//读取接收的数据
try {
while (inputStream1.available() > 0) {
inputStream1.read(readBuffer1);
queue.put(readBuffer1);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
};
executorService.execute(insert1);//生产者
executorService.execute(new PacketReturn1());//消费者
好像是高速率下传输会出现接收延迟，eg：
发送端一次发送60字节，接收端缓存90字节，但是前30字节有值，后60字节全零，发送端剩下的3字节在接收端延迟接收。怎么解？