Java-Timeout-Zeitraum zum Lesen der seriellen Schnittstelle

Question

Ich habe einen Code zum Lesen der seriellen Schnittstelle über RXTX. Aber ich möchte, dass der gepufferte Leser des Eingabestreams überprüft, ob die Daten kommen oder nicht. Nach dem Timeout sollte es das Programm oder den Thread stoppen, mit dem ich begonnen habe, serialReader zu lesen.

Answer 1

Möglicherweise Timer (Schedule) in Verbindung mit Ihrer Leseschleife verwenden.

Verwendung folgend -> timer.schedule ('your_read_task', 'time_when_you_want_to_end')

Answer 2

Man könnte so etwas tun:

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

nur einen Entwurf für den Anfang. Die Leseoperation wird in einem separaten Thread durchgeführt. Dann warten Sie in Ihrem Hauptthread darauf, dass es beendet wird und eine TimeoutException abfängt. Wenn dies passiert, können Sie Ihre Ressourcen bereinigen (schließen Sie den COM-Port !!) und beenden Sie. Wenn es nicht auftritt, war das Lesen erfolgreich.

---

Einige Ressourcen:

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

---

Basierend auf Ihren Code:

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

daran, dass ich nicht ein IDE haben, dies zu schreiben, noch kompiliert, kann es Tippfehler sein und für einige Anpassung benötigen.

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