0

上下文:我正在以 115.2 Kbaud 从串行端口读取数据。读取的数据使用 PrintWriter 打印,然后我将其附加到 JTextArea。

一切正常,但在将流从串行端口发送到我的 PrintWriter 的方法完成之前,JTextArea 中的文本不会出现。我希望它更接近实时显示,因为我有时会一次接收超过 20-30 MB 的文本,并且随着程序执行,文本的一般流如何变化将是有价值的。

我在 这里使用 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 用于输出(所有这些都是字符串)。

我不确定我在这里做错了什么。执行此代码时,Java 进程将无限期冻结。

我是否正确假设在任何 VerifierTask 线程中创建的 VerifierReader 都绑定到该线程,因此我的 thread.sleep 和 while(true) 语句不再构成问题?

4

1 回答 1

2

不要在主 Swing 事件线程(EDT)上调用 Thread.sleep 或 do while (true)。曾经。而是在后台线程中执行此类操作,例如通过 SwingWorker 提供的线程。您将使用发布/处理方法对来获取 JTextArea 的中间结果。

有关这方面的更多信息,请查看教程:Swing 中的并发

于 2011-11-18T18:58:27.833 回答