11

我正在为控制台应用程序实现 GUI，我需要在指定的时间间隔内执行一些操作（例如，解析 XML 文件）。我决定将 javax.swing.Timer 与 SwingWorker 一起使用，以确保这些操作不会使我的应用程序无响应。

我以这种方式实现了计时器：

public class DataUpdateTimer extends Timer {

    private String dataFlowControllerXML = null;
    private DataUpdateWorker dataUpdateWorker = null;

    public class DataUpdateWorker extends SwingWorker {

        private String dataFlowControllerXML = null;

        DataUpdateWorker(String dataFlowControllerXML) {
            super();
            this.dataFlowControllerXML = dataFlowControllerXML;
        }

        @Override
        protected Boolean doInBackground() throws Exception {

            Thread.sleep(300);
            return Boolean.TRUE;
        }

    }

    public class DataUpdateIntervalListener implements ActionListener {

        public void actionPerformed(ActionEvent e) {
            DataUpdateTimer timer = (DataUpdateTimer)e.getSource();
            DataUpdateWorker dataUpdateWorker = timer.getDataUpdateWorker();

            if (dataUpdateWorker != null)
                if (dataUpdateWorker.isDone()) {
                    Boolean updateResult = Boolean.FALSE;
                    try {
                        updateResult = (Boolean)dataUpdateWorker.get();
                    } catch (InterruptedException ex) {

                    } catch (ExecutionException ex) {

                    }

                    dataUpdateWorker = null;
                }

            // Creating new worker thread here
            if (dataUpdateWorker == null) {
                timer.dataUpdateWorker = new DataUpdateWorker(timer.dataFlowControllerXML);

                // Starting a new worker thread for parsing Data Flow Controller's XML
                timer.dataUpdateWorker.execute();
                return;
            }
        }
    }

    DataUpdateTimer(Integer dataUpdateInterval, String dataFlowControllerXML) {

        super(dataUpdateInterval.intValue(), null);
        this.dataFlowControllerXML = dataFlowControllerXML;
        addActionListener(new DataUpdateIntervalListener());
    }

    @Override
    public void stop() {
        super.stop();
        if (dataUpdateWorker != null) {
            if (!dataUpdateWorker.isDone() || !dataUpdateWorker.isCancelled())
                dataUpdateWorker.cancel(true);
        }
    }
}

...并按如下方式使用它：

new DataUpdateTimer(1000, dataFlowControllerXML).start();

一切都如我所愿。Timer 创建一个新的 SwingWorker 实例并执行它。工作人员完成后，将创建并执行新的工作人员。

我感到困惑的是，在工作线程完成后，我仍然可以在 Netbeans 的调试窗口（例如 SwingWorker-pool-3-thread-1）或 Windows 任务管理器（线程完成后运行线程不会减少）。SwingWorker 线程的数量限制为 10 个，但让它们运行让我很尴尬。

在简单线程使用的情况下：

Thread th = new Thread(new Runnable() {

    public void run() {
        int a = 0;
    }
});
th.start();

该线程在执行后自动消失。

这种 SwingWorker 行为正常吗？

4

1 回答 1

11

是的，这很正常。正如线程的名字所暗示的，swing workers 的模型（后台）动作被委托给一个线程池。工作完成后，线程将返回到池中，以便其他工作人员可以使用它。这消除了创建/销毁线程的一些开销，这些开销可能很昂贵。

顺便说一句，后台线程不会永远存在。查看源代码，SwingWorker我看到：

//from SwingWorker.java (c) Sun Microsystems/Oracle 2009
executorService =
            new ThreadPoolExecutor(1, MAX_WORKER_THREADS,
                                   10L, TimeUnit.MINUTES,
                                   new LinkedBlockingQueue<Runnable>(),
                                   threadFactory);

这表明线程将在空闲 10 分钟后死亡。

于 2011-03-01T16:43:54.883 回答