Duvidas na Utilização de Thread

Estou desenvolvendo um programa para coletar as informações que estão trafegando na porta serial, mais precisamente: tenho um medidor de vazão de leite na outra ponta e preciso coletar a quantidade que está sendo coletado.

Após inúmeros garimpos pelo fórum cheguei ao seguintes métodos:

public void LerDados(){
        if (Leitura == true){
            try {
                entrada = porta.getInputStream();
            } catch (Exception e) {
                JOptionPane.showMessageDialog(null,"Erro.STATUS: " + e);
                System.exit(1);
              }
            try {
                porta.addEventListener(this);
//                JOptionPane.showMessageDialog(null,"SUCESSO. Porta aguardando...");
            } catch (Exception e) {
                JOptionPane.showMessageDialog(null,"Erro ao criar listener. STATUS: " + e);
                System.exit(1);
              }
            porta.notifyOnDataAvailable(true);
            try {
                threadLeitura = new Thread(this);
                threadLeitura.start();
                run();
            } catch (Exception e) {
                JOptionPane.showMessageDialog(null,"Erro ao iniciar leitura: " + e);
              }
        }
    }
   
    //método RUN da thread de leitura
    public void run(){
        try {
            Thread.sleep(1000);
        } catch (Exception e) {
            JOptionPane.showMessageDialog(null,"Erro. Status = " + e);
          }
    }
    
    //gerenciador de eventos de leitura na serial
    public void serialEvent(SerialPortEvent ev){
        switch (ev.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:
            byte[] bufferLeitura = new byte[20];
            try {
                while ( entrada.available() > 0 ) {
                    nodeBytes = entrada.read(bufferLeitura);
                }
                String Dadoslidos = new String(bufferLeitura);
                
                telaPrincipal.jlsQtdMed.setText(Dadoslidos);
                  
                while ( entrada.available() > 0 ) {
                    JOptionPane.showMessageDialog(null, Dadoslidos);
                }
                if (bufferLeitura.length == 0) {
                    linArq = "Nada foi lido!";
                    GerarArquivo(linArq);
                } else if (bufferLeitura.length == 1 ){
                    linArq = "Apenas um byte foi lido!";
                    GerarArquivo(linArq);
                } else {
                    linArq = "LIDO: " + Dadoslidos;
                    GerarArquivo(linArq);
                    
                    telaPrincipal.jlsQtdMed.setText(Dadoslidos);
                    
                    String lido = Dadoslidos.replaceAll("\\D", "");
                    JOptionPane.showMessageDialog(null, "Somente número: " + lido);
                    
                    sSql = "Update Usu_T001Med Set Usu_QtdMed = (?) Where Usu_NumSer = (?)";
                    try{  
                        PreparedStatement prepared = conn.prepareStatement(sSql);  
                        prepared.setString(1, Dadoslidos);  
                        prepared.setString(2, infBanco.get(5).toString());  
                        
                        JOptionPane.showMessageDialog(null, "SQL: " + sSql);
                        
                        prepared.executeUpdate();  
                    }catch (SQLException e){  
                        e.printStackTrace();  
                    }
                }
            } catch (Exception e) {
                JOptionPane.showMessageDialog(null,"Erro durante a leitura: " + e);
              }
            break;
        }
    }