Время ожидания Java для чтения последовательного порта

Question

У меня есть код для чтения последовательного порта через rxtx. Но я хочу, чтобы этот буферизатор ввода-потока должен проверять на определенное время, что данные идут или нет. После таймаута он должен остановить программу или поток, которые я начал читать serialReader.

Answer 1

Возможно использование таймера (расписания) в сочетании с вашим циклом чтения.

Использование следующим образом -> timer.schedule ('your_read_task', 'time_when_you_want_to_end')

Answer 2

Вы могли бы сделать что-то вроде этого:

ExecutorService exec = new Executors.newSingleThreadExecutor(); 

// ... where you want to start reading and wait: 
Future<String> readResult = exec.submit(new Callable<String>(){ 
    @Override public String call(){ 
      // Your reading code here. 
    } 
}); 

try{ 
    String strResult = readResult.get(1, TimeUnit.MINUTES); 
} catch(TimeoutException tex) { 
    // handle Timeout 
} catch (/*... you should also catch other exceptions like */ IOException ioex){} 

Просто план для начинающих. Операция чтения будет выполняться в отдельном потоке. Затем в основной теме вы ждете его завершения, перехватывая исключение TimeoutException. Если это произойдет, вы можете очистить свои ресурсы (закрыть COM-порт!) И выйти. Если это не происходит, чтение было успешным.

---

Некоторые ресурсы:

• Executors
• ExecutorService
• Future
• Callable
• Oracle Executors Tutorial

---

на основе кода:

public class SerialReaderWithTimeout implements Runnable { 
private final InputStream inputStream; 
private final ExecutorService exec = Executors.newSingleThreadExecutor(); 

public SerialReaderWithTimeout(InputStream in) { 
    inputStream = in; 

    br = new BufferedReader(new InputStreamReader(inputStream)); 
    try { 
     bw = new BufferedWriter(new FileWriter(FILENAME)); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

private String readWithTimeout(){ 
    String strResult = null; 

    Future<String> readResult = exec.submit(new Callable<String>(){ 
    @Override public String call(){ 
      return br.readLine(); 
    }}); 

    try{ 
     strResult = readResult.get(10, TimeUnit.MINUTES); 
    } catch(TimeoutException tex) { 
     // handle Timeout: NOP -> Just return null 
    } catch (Exception ex){ 
     // handle Exception 
     throw; 
    } 

    return strResult; 
} 

public void run() { 
    String inputLine = null; 
    try { 

     //while ((inputLine = br.readLine()) != null) { 
     while ((inputLine = readWithTimeout()) != null) { 
      //series.put(num, inputLine); 
      //num++; 
      bw.write(inputLine); 
      bw.newLine(); 
      bw.flush(); 
      System.out.println(inputLine); 

      if (inputLine.trim().startsWith("DATE") | inputLine.trim().startsWith("REMARK") 
        | inputLine.trim().startsWith("TESTED BY")) { 
       serialPort.close(); 
       inputStream.close(); 
       br.close(); 
       bw.close(); 
       break; 
      } 
     } 

     //new CompareClass(); 
    } catch (IOException e) { 
     System.out.println(e.getMessage()); 
    } 
} 

виду, что я не использовал IDE, чтобы написать это и не скомпилирован, может быть опечаток и потребность в некоторой адаптации.

Answer 3

public ReadWithoutTimings() { 
    super(); 
    num = 1; 

    try { 


    try { 

     serialPort = (SerialPort) portId.open("Read1", 2000); 
    } catch (PortInUseException e) { 
     System.out.println(e); 
     JOptionPane.showMessageDialog(null, e); 
    } 

    try { 
     serialPort.setSerialPortParams(9600, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE); 

    } catch (UnsupportedCommOperationException e1) { 
     System.out.println(e1); 
    } 
    try { 
     in = serialPort.getInputStream(); 
    } catch (IOException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 

    /*timer.schedule(new TimerTask() {    
     @Override 
      public void run() { 

      (new Thread(new SerialReader(in))).start(); 
       } 

     }, time);*/ 
    (new Thread(new SerialReader(in))).start(); 
} 

public class SerialReader implements Runnable { 


    public SerialReader(InputStream in) { 
     inputStream = in; 
     try { 
      in.close(); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
     br = new BufferedReader(new InputStreamReader(inputStream)); 
     try { 
      bw = new BufferedWriter(new FileWriter(FILENAME)); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
    } 

    public void run() { 
     String inputLine = null; 
     try { 



      while ((inputLine = br.readLine()) != null) { 
       //series.put(num, inputLine); 
       //num++; 
       bw.write(inputLine); 
       bw.newLine(); 
       bw.flush(); 
       System.out.println(inputLine); 

       if (inputLine.trim().startsWith("DATE") | inputLine.trim().startsWith("REMARK") 
         | inputLine.trim().startsWith("TESTED BY")) { 
        serialPort.close(); 
        inputStream.close(); 
        br.close(); 
        bw.close(); 
        break; 
       } 
      } 

      //new CompareClass(); 
     } catch (IOException e) { 
      System.out.println(e.getMessage()); 
     } 
    }