java - 带有 SerialEvent 的 SwingWorker worker(应用于 JTextField)

Question

我正在尝试用 java 制作一个 serialmonitor，但我被卡住了。我尝试将文本(串行输入)应用到 JTextArea。我尝试使用 SwingWorker，我取得了一些成功，但还不够好。

我有一个事件(SerialEventListener)读取输入数据。在这种情况下，我试图将传入的数据附加到在另一个类中声明的 JTextArea，并且附加方法将不起作用。我读过它不应该工作，我需要使用 SwingWorker 而我做到了。问题是只有当我在按钮事件中发出命令执行时，SwingWorker 的执行过程才会启动。总之，我想在从串行端口获取数据时执行 swingworker 例程。示例:serialevent(到达的数据)-> appedrutine(swingworker)-> 完成这是我的代码:

保存我的图形组件的类:中心面板

import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.Dimension;
import java.awt.GridBagConstraints;
import java.awt.GridBagLayout;
import java.awt.Insets;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import javax.swing.BoxLayout;
import javax.swing.JButton;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTabbedPane;
import javax.swing.JTextArea;
import javax.swing.border.TitledBorder;


public class centerPanel implements ActionListener{

private JTabbedPane tabbed_pane = new JTabbedPane();
public JPanel tab_source    = new JPanel();
public JPanel tab_graphical = new JPanel();
private updateData updateText_method;
private JTextArea data_content = new JTextArea();
private JButton Freeze, Clear, Reload;

public centerPanel(){

    tabbed_pane.setBorder(new TitledBorder("Data visualization"));

    Freeze = new JButton("Freeze");
    Freeze.addActionListener(this);

    Clear  = new JButton("Clear");
    Clear.addActionListener(this);

    Reload = new JButton("Reload");
    Reload.addActionListener(this);

    BoxLayout box_layout = new BoxLayout(tab_source,BoxLayout.Y_AXIS);
    tab_source.setLayout(box_layout);

    data_content.setEditable(false);
    data_content.setForeground(Color.WHITE);
    data_content.setBackground(Color.DARK_GRAY);

    tab_source.add(new JScrollPane(data_content));

    JPanel temp_panel = new JPanel(new GridBagLayout());
    GridBagConstraints c = new GridBagConstraints();

    temp_panel.setBorder(new TitledBorder("Data control"));
    temp_panel.setPreferredSize(new Dimension(MainFrame.window_width,(int)(MainFrame.window_height*0.07)));
    temp_panel.setMaximumSize(new Dimension(MainFrame.window_width,  (int)(MainFrame.window_height*0.12)));

    c.gridx = 0;
    c.insets = new Insets(0,8,8,0);

    temp_panel.add(Freeze,c);
    c.gridx = 1;
    temp_panel.add(Clear,c);
    c.gridx = 2;
    temp_panel.add(Reload,c);

    tab_source.add(temp_panel,BorderLayout.LINE_END);

    tabbed_pane.addTab("Text mode",tab_source);
    tabbed_pane.addTab("Graphic mode",tab_graphical);

}

public JTabbedPane getTabs(){

    return tabbed_pane;

}

public void updateData(){

     updateText_method = new updateData(data_content);
     updateText_method.execute();

}

@Override
public void actionPerformed(ActionEvent event) {

    if(event.getSource() == Clear){

        updateData();

    }

}

}

这是我的 serialMonitor 类(从串口读取)

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import javax.comm.CommPortIdentifier;
import javax.comm.SerialPort;
import javax.comm.SerialPortEvent;
import javax.comm.SerialPortEventListener;
import javax.swing.JOptionPane;


public class serialMonitor implements SerialPortEventListener {

private static CommPortIdentifier pid;
private static SerialPort port;
private InputStream inputstream;
private static OutputStream outputstream;
public static int data ;


public void openPort(String portname, int baudrate){

    System.out.println(new String(""+ baudrate + "xx" +portname));
    try {

         pid=CommPortIdentifier.getPortIdentifier(portname);

         port=(SerialPort)pid.open("owner",2000);
         port.setSerialPortParams(baudrate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
         outputstream=port.getOutputStream();
         inputstream=port.getInputStream();
         port.addEventListener(this);
         port.notifyOnDataAvailable(true);

     } catch (Exception e) {
         e.printStackTrace();
         JOptionPane.showMessageDialog(new Frame("Info"), "Connection problems!");} 


}

public void closePort(String mesaj){

    try{
         port.close();
       } catch (Exception e) {JOptionPane.showMessageDialog(new Frame("Info"), "Connection problems!");}

}

@Override
public void serialEvent(SerialPortEvent sE) {

    try {

        inputstream=port.getInputStream();

    } catch (Exception e) {

        JOptionPane.showMessageDialog(new Frame("Info"), "Connection problem! Cant read data from quadcopter");
    }

    if (sE.getEventType()==SerialPortEvent.DATA_AVAILABLE) {

        try
        {
            while ( ( data = inputstream.read()) > -1 ){

              System.out.println(data);

              { 
                 //This is where i want to make the update
                 //something like centerPanel_obj.updataData()
                 //
              } 

            }

        }
        catch ( IOException e )
        {
            e.printStackTrace();
            System.exit(-1);
        }

    }



}





}

这是我的 updataData 类(SwingWorker 所在的位置)

import java.util.List;
import javax.swing.JTextArea;
import javax.swing.SwingWorker;

public class updateData extends SwingWorker<Integer, String> {

private final JTextArea messagesTextArea;

public updateData(final JTextArea messagesTextArea) {
this.messagesTextArea = messagesTextArea;
}

 @Override
 protected Integer doInBackground() throws Exception {

int i;
  for ( i = 0; i<50; i++) 
    publish(new String(""+i));

 return 1;

}

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

for (final String string : chunks) {
  messagesTextArea.append(string);
  messagesTextArea.append("\n");
  }
}

注意:我会接受所有关于我的代码和我的描述的批评，所以如果你有一些……不要害羞。谢谢!

Answer 1

您可以做很多事情。但我会给你一些基础知识。

最终用户在您的应用程序中所做的一切都在单个线程上运行 - 事件调度线程 (EDT) - 除非您有意将其放在不同的线程上。因此，如果用户单击一个按钮，而您开始执行需要一段时间的操作，则 UI 将卡住，直到您完成为止。

解决这个问题的简单方法是启动一个新线程来完成您的工作。

但是...您还必须考虑任何 UI 更新也必须在 EDT 上完成(哦，不行!)。 SwingUtilities.invokeLater(Runnable doRun)已创建，以便您可以将进程放入队列中以在 EDT 上运行。

SwingWorker's工作是让整个 rigamarole 更容易。它为 1) 在 EDT 的线程中执行代码和 2) 在 EDT 的线程中执行代码(在第一个线程完成后)提供接口(interface)

---

现在，您的问题中有一些不清楚的地方:

• serialMonitor 甚至不是代码的一部分 - 我不确定您想用它做什么
• 不清楚您是希望用户操作触发 UI 更新，还是串行端口上的事件(通信)应该触发更新

如果您的 SerialMonitor 已经在其自己的线程上执行(而不是在 EDT 上)，我认为它必须如此，那么每当您需要更新 UI 时，您只需像这样包装调用这个:

SwingUtilities.invokeLater(new Runnable(){

    @Override
    public void run() {
        //Insert your code to update UI here
    }
});

当然，您需要授予 SerialMonitor 访问 UI 部分的权限才能更新。