Почему мои потоки SwingWorker продолжают работать, даже если они выполнены? - PullRequest
Новая
       1

Почему мои потоки SwingWorker продолжают работать, даже если они выполнены?

11 голосов
/ 01 марта 2011

Я реализую графический интерфейс для консольного приложения, и мне нужно выполнить некоторые действия (например, проанализировать файл 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();

Все работает, как я хочу. Таймер создает новый экземпляр 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 нормально?

1 Ответ

11 голосов
/ 01 марта 2011

Да, это нормально.Как следует из названия потока, модели (фоновые) действия колеблющихся работников делегируются пулу потоков .Когда работа завершена, поток возвращается в пул, чтобы его мог использовать другой работник.Это устраняет некоторые накладные расходы при создании / уничтожении потоков, которые могут быть дорогими.

Кстати, фоновые потоки не будут держаться вечно.Глядя на источник для SwingWorker я вижу: 

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

Это указывает на то, что потоки умрут после простоя в течение 10 минут.

...