PrintWriter для JTextArea, ничего не отображается, пока не будет вызван вызываемый метод - PullRequest
Новая
       12

PrintWriter для JTextArea, ничего не отображается, пока не будет вызван вызываемый метод

0 голосов
/ 18 ноября 2011

Контекст: я читаю данные из последовательного порта со скоростью 115,2 КБод.Прочитанные данные печатаются с использованием PrintWriter, который затем добавляется в JTextArea.

Все работает хорошо, но текст в JTextArea не появляется, пока не завершится метод отправки потока из последовательного порта в мой PrintWriter.Мне бы хотелось, чтобы он отображался ближе к реальному времени, так как иногда я получаю свыше 20–30 МБ текста за раз, и то, как общий поток текста изменяется при выполнении программы, было бы полезно.

Я использую метод PrintWriter для JTextArea здесь .Я думаю, что решение, вероятно, связано с потоками и PipedWriter / PipedReader, но каждая попытка реализовать это с треском провалилась.

Спасибо за вашу помощь. 

//code calling method;  VerifierReader does not inherit from Reader 
//or any such class. it's wholly homegrown. I send it the PrintWriter 
//as out, telling it to output there


verifierInstance=new VerifierReader("COM3", verifierOutputLocString.getText());
verifierInstance.setSysOutWriter(out);
verifierInstance.readVerifierStream();

// and the relevant code from VerifierReader

public void setSysOutWriter (PrintWriter outWriter) {
        sysOutWriter=new PrintWriter(outWriter);            

    }
public void readVerifierStream() throws SerialPortException, 
InterruptedException{

    try{
        sysOutWriter.println("Listening for verifier...");
                    //sysOutWriter.flush();

        verifierPort.addEventListener(new verifierListener());

        lastReadTimer=System.currentTimeMillis();

        while(verifierPort.isOpened()) {

            Thread.sleep(1000);
            //System.out.println(timeOut);
            if( ((long)(System.currentTimeMillis()-lastReadTimer))>timeOut){
                sysOutWriter.println("Finished");
                verifierPort.removeEventListener();
                verifierPort.closePort();

            }
        }
    }

    finally {

        if (verifierPort.isOpened()) {
            verifierPort.closePort();
        }

        bfrFile.close();

    }
}








private class verifierListener implements SerialPortEventListener{

    String outBuffer;




    public void serialEvent(SerialPortEvent event) {
        if(event.isRXCHAR()){//If data is available
            timeOut=200;
            lastReadTimer=System.currentTimeMillis();
            if(event.getEventValue() > 0){//Check bytes count in the input buffer

                try {
                    byte[] buffer = verifierPort.readBytes(event.getEventValue());
                    outBuffer=new String(buffer);

                    bfrFile.print(outBuffer);
                    sysOutWriter.print(outBuffer);
                        //bfrFile.flush();
                        //sysOutWriter.flush();
                }
                catch (SerialPortException ex) {
                    sysOutWriter.println(ex);
                }

            }
        }



    }
}

Редактировать:

Я попытался выполнить то, что было рекомендовано ниже, и внес следующие изменения: 

 private class VerifierTask extends SwingWorker<Void, String> {



    public VerifierTask() throws IOException, SerialPortException, InterruptedException{
        verifierInstance= new VerifierReader(streamReader);
        verifierInstance.setReaderIO("COM3", verifierOutputLocString.getText());
        verifierInstance.readVerifierStream();

    }


    @Override
    protected Void doInBackground() throws IOException{
        int charItem;
        char[] charBuff = new char[10];
        String passString;

        while ((charItem = streamReader.read(charBuff, 0, 10)) !=-1) {

            passString = new String(charBuff);
            publish(passString);
        }


        return null;
    }

    @Override 
    protected void process(List<String> outList) {

        for (String output : outList) {
            outputArea.append(output);
        }

    }



}

был добавлен, и я изменил свою кнопку, чтобы немедленно вызывать новый экземпляр класса VerifierTask, в дополнение к тому, что VerifierReader реализовал PipedWriter для вывода (со всеми этими строками).

I 'Я не уверен, что я делаю не так здесь.Когда этот код выполняется, процесс Java просто зависает на неопределенный срок.

Правильно ли я предполагаю, что VerifierReader, созданный в любом потоке VerifierTask, привязан к этому потоку, и, таким образом, мои выражения thread.sleep и while (true) больше не представляют проблемы?

1 Ответ

2 голосов
/ 18 ноября 2011

Не вызывайте Thread.sleep и не выполняйте while (true) в главном потоке событий Swing, EDT. Когда-либо. Вместо этого делайте такие вещи в фоновом потоке, например, предоставляемом через SwingWorker. Вы могли бы использовать пару методов публикации / процесса для получения промежуточных результатов для вашей JTextArea.

Подробнее об этом можно узнать из учебника: Параллельность в Swing .

...