Безопасный способ заменить AWT EventQueue при запуске приложения Swing - PullRequest
Новая
       12

Безопасный способ заменить AWT EventQueue при запуске приложения Swing

3 голосов
/ 26 марта 2012

Различные спорадические проблемы в поддерживаемом мною приложении Swing, по-видимому, вызваны тем, что оно заменяет очередь событий AWT по умолчанию своей собственной версией, использующей Toolkit.getDefaultToolkit().getSystemEventQueue().push(new AEventQueue()).См., Например, Потоки и взаимоблокировки в приложении Swing .Описанная там проблема была решена, но мои тесты (с использованием FEST Swing) теперь, как правило, зашли в тупик.

Я подозреваю, что лучшим решением было бы заменить очередь событий в начале инициализации приложения долюбые компоненты Swing созданы.Однако есть некоторые зависимости, которые делают это неловким, поэтому в настоящее время я пытаюсь найти безопасный способ «протолкнуть» новую очередь событий после инициализации, где это в настоящее время делается.

Два подхода, которые япробовали:

  • выдвинуть новую очередь в EDT с помощью SwingUtilities.invokeLater();
  • выдвинуть новую очередь в главном потоке после инициализации и после использования invokeLater(), чтобы избежать взаимоблокировкисо всем, что уже запущено в старом EDT.

Что я мог бы ожидать после прочтения https://stackoverflow.com/a/8965448/351885,, так это то, что первый подход может работать в Java 7, но что-то вроде второго может понадобиться вJava 1.6.Действительно, второй работает в Java 1.6, в то время как в Java 7 оба успешно завершаются, но работают очень медленно.Это может быть просто проблемой FEST, так как само приложение кажется довольно отзывчивым.

Так что я в значительной степени вынужден использовать второй подход, который по крайней мере работает в Java 1.6, но я хотел бы знать - еслиесть более безопасный способ реализовать это, так как кажется, что он может быть уязвим к состоянию гонки, если событие появляется в существующей очереди после invokeLater, но до создания новой очереди;- если есть другой подход, я должен использовать вместо него.

Подробнее

Первое «решение» выглядит так: 

    initApplication();
    SwingUtilities.invokeLater(new Runnable() {
        @Override
        public void run() {
            Toolkit.getDefaultToolkit().getSystemEventQueue().push(new CustomEventQueue());
        }
    });

Когда я скомпилирован и запущен с использованием Java 1.6, я не понимаю, что он делает.Кажется, что поток ожидает блокировки, которую он уже удерживает: 

"AWT-EventQueue-1" prio=10 tid=0x00007f9808001000 nid=0x6628 in Object.wait() [0x00007f986aa72000]
   java.lang.Thread.State: WAITING (on object monitor)
    at java.lang.Object.wait(Native Method)
    - waiting on <0x00000007d9961cf0> (a atlantis.gui.AEventQueue)
    at java.lang.Object.wait(Object.java:502)
    at java.awt.EventQueue.getNextEvent(EventQueue.java:490)
    - locked <0x00000007d9961cf0> (a atlantis.gui.AEventQueue)
    at java.awt.EventDispatchThread.pumpOneEventForFilters(EventDispatchThread.java:247)

Второе «решение» выглядит так: 

    initApplication();
    try {
        SwingUtilities.invokeAndWait(new Runnable() {
            @Override
            public void run() {
                logger.debug("Waiting for AWT event queue to be empty.");
            }
        });
    } catch (InterruptedException e) {
        logger.error("Interrupted while waiting for event queue.", e);
    } catch (InvocationTargetException e) {
        logger.error("Error while waiting for event queue.",e);
    }
    Toolkit.getDefaultToolkit().getSystemEventQueue().push(new CustomEventQueue());

Как указано выше, похоже, что это работает нормальнов Java 1.6, но я не уверен, что это действительно безопасно.

Я не понял, что происходит при использовании Java 7, но основной поток, по-видимому, тратит много времени на сон метода org.fest.swing.timing.Pause.pause()Вот почему я подозреваю, что это может быть проблема, связанная с FEST.

1 Ответ

3 голосов
/ 26 марта 2012

Поскольку я не вижу причины для сброса текущего EDT на новый, мои вопросы

1) есть ли у вас

  • Завершение Java, вне памяти ...

  • Исключения RepaintManager,

2) в основном вы можете

  • блокировка тока EDT с Thread.sleep(int), с setVisible(false) для вызванного JComponent,

  • если есть EDT, то вы должны использовать invokeLater, если не активен, то вы можете выбрать между invokeLater из invokeAndWait

код 

if (EventQueue.isDispatchThread()) {
    SwingUtilities.invokeLater(new Runnable() {

        @Override
        public void run() {
            //some stuff
        }
    });
} else {
    try {
        SwingUtilities.invokeAndWait(new Runnable() {

            @Override
            public void run() {
                //some stuff
            }
        });
    } catch (InterruptedException ex) {
        Logger.getLogger(IsThereEDT.class.getName()).log(Level.SEVERE, null, ex);
    } catch (InvocationTargetException ex) {
        Logger.getLogger(IsThereEDT.class.getName()).log(Level.SEVERE, null, ex);
    }
}

3) извещение invokeAndWait должно быть вызвано из EDT, в противном случае вызвано EDT exceptions с блокировкой текущего EDT

4) если нет активного EDT, то нет причины push() что-то для EventQueue

5) простой код тестирования для всего вышеперечисленного .. 

import java.awt.EventQueue;
import java.lang.reflect.InvocationTargetException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.*;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.*;

public class IsThereEDT {

    private ScheduledExecutorService scheduler;
    private AccurateScheduledRunnable periodic;
    private ScheduledFuture<?> periodicMonitor;
    private int taskPeriod = 30;
    private SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
    private Date dateRun;
    private JFrame frame1 = new JFrame("Frame 1");

    public IsThereEDT() {
        scheduler = Executors.newSingleThreadScheduledExecutor();
        periodic = new AccurateScheduledRunnable() {

            private final int ALLOWED_TARDINESS = 200;
            private int countRun = 0;
            private int countCalled = 0;
            private int maxCalled = 10;

            @Override
            public void run() {
                countCalled++;
                if (countCalled < maxCalled) {
                    if (countCalled % 3 == 0) {
                        /*if (EventQueue.isDispatchThread()) {
                            SwingUtilities.invokeLater(new Runnable() {

                                @Override
                                public void run() {
                                    //some stuff
                                }
                            });
                        } else {
                            try {
                                SwingUtilities.invokeAndWait(new Runnable() {

                                    @Override
                                    public void run() {
                                        //some stuff
                                    }
                                });
                            } catch (InterruptedException ex) {
                                Logger.getLogger(IsThereEDT.class.getName()).log(Level.SEVERE, null, ex);
                            } catch (InvocationTargetException ex) {
                                Logger.getLogger(IsThereEDT.class.getName()).log(Level.SEVERE, null, ex);
                            }
                        }*/
                        SwingUtilities.invokeLater(new Runnable() {

                            @Override
                            public void run() {
                                System.out.println("Push a new event to EDT");
                                frame1.repaint();
                                isThereReallyEDT();
                            }
                        });
                    } else {
                        if (this.getExecutionTime() < ALLOWED_TARDINESS) {
                            countRun++;
                            isThereReallyEDT(); // non on EDT
                        }
                    }
                } else {
                    System.out.println("Terminating this madness");
                    System.exit(0);
                }
            }
        };
        periodicMonitor = scheduler.scheduleAtFixedRate(periodic, 0, taskPeriod, TimeUnit.SECONDS);
        periodic.setThreadMonitor(periodicMonitor);
        SwingUtilities.invokeLater(new Runnable() {

            @Override
            public void run() {
                isThereReallyEDT();
                frame1.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
                frame1.getContentPane().add(new JLabel("Hello in frame 1"));
                frame1.pack();
                frame1.setLocation(100, 100);
                frame1.setVisible(true);
            }
        });
        try {
            Thread.sleep(500);
        } catch (InterruptedException ex) {
            Logger.getLogger(IsThereEDT.class.getName()).log(Level.SEVERE, null, ex);
        }
        SwingUtilities.invokeLater(new Runnable() {

            @Override
            public void run() {
                JFrame frame2 = new JFrame("Frame 2");
                frame2.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
                frame2.getContentPane().add(new JLabel("Hello in frame 2"));
                frame2.pack();
                frame2.setLocation(200, 200);
                frame2.setVisible(true);
                isThereReallyEDT();
            }
        });
    }

    private void isThereReallyEDT() {
        dateRun = new java.util.Date();
        System.out.println("                         Time at : " + sdf.format(dateRun));
        if (EventQueue.isDispatchThread()) {
            System.out.println("EventQueue.isDispatchThread");
        } else {
            System.out.println("There isn't Live EventQueue.isDispatchThread, why any reason for that ");
        }
        if (SwingUtilities.isEventDispatchThread()) {
            System.out.println("SwingUtilities.isEventDispatchThread");
        } else {
            System.out.println("There isn't Live SwingUtilities.isEventDispatchThread, why any reason for that ");
        }
        System.out.println();
    }

    public static void main(String[] args) {
        IsThereEDT isdt = new IsThereEDT();
    }
}

abstract class AccurateScheduledRunnable implements Runnable {

    private ScheduledFuture<?> thisThreadsMonitor;

    public void setThreadMonitor(ScheduledFuture<?> monitor) {
        this.thisThreadsMonitor = monitor;
    }

    protected long getExecutionTime() {
        long delay = -1 * thisThreadsMonitor.getDelay(TimeUnit.MILLISECONDS);
        return delay;
    }
}
...