0

我正在开发一个网络抓取工具,该工具应该对抓取的数据执行各种操作。

正因为如此,我需要各种不同的 GUI 以有序的方式工作,因此,我需要 main 方法在每个完成它的目的之前等待。

经过一段时间的搜索,我发现了以下 StackOverflow 问题,这些问题提供了一些关于如何解决问题的线索,但我无法实现,因为它们与我的情况有些不同:

如何等待文本字段中的输入 如何让主线程等待不同的线程完成


我知道我可以使用监听器触发代码到一个/GUI的组件(例如一个按钮),但是我很难让主线程等待那个监听器唤醒它,而代码GUI的线程(当有一个时)由主线程初始化......


这是一个简化的代码,用于演示程序应该如何工作:

public class Main {
    /*
     * Waiter is a simple GUI with just an "Start" button in it. Here in place of my actual GUIs.
     */
    private static Waiter auth; //Represents my NTLM-authentication form.
    private static Waiter status; //Represents a status-feedback GUI that will be displayed during processing.
    private static Waiter operation; //Represents a GUI in with the user choses what to do with the gathered data.

    public static void main(String[] args) throws InterruptedException {
        auth = new Waiter();
        auth.setVisible(true);
        System.out.println("NTLM Authentication form. Should wait here until user has filled up the GUI and clicked \"Start\".");
        System.out.println("Authenticates WebClient's NTLM using data inputed to the GUI...");
        auth.dispose();
        Thread srt = new Thread(status = new Waiter());
        srt.start();
        status.setVisible(true);
        //Performs webscraping operations...
        System.out.println("Prepares the webscraped data here...Things like downloading files and/or parsing text...");
        System.out.println("Keeps the user aware of the progress using the \"status\" GUI.");
        status.setVisible(false);
        //Clears the status GUI.
        operation = new Waiter();
        operation.setVisible(true);
        System.out.println("Operation selection form. Should wait here until user selects an option.");
        System.out.println("Starts performing the operation(s)...");
        operation.dispose();
        status.setVisible(true);
        System.out.println("Performs the operation(s), while giving status-feedback to the user.");
        status.setVisible(false);
        System.out.println("Displays a file-save dialog to save the results.");
        System.out.println("And finally, displays a \"End of operations\" dialog before ending.");
    }
}

更新1:我遇到的主要困难是实现这样的事情(这是我想做的):

//Main method...code...
Thread srt = new Thread(status = new Waiter());
//Before "srt.start();"...
status.startButton.addActionListener(new ActionListener() {
  @Override
  public void actionPerformed(ActionEvent e) {
    main.continueExecution();
  }
});
//Thread's run() being something like "status.setVisible(true); main.waitGUI();"
srt.start();
//continues here after the Listener is triggered...more code...

而不是这个(如果我理解正确的话,大多数其他人的解决方案是什么......)(如果可能的话,这是我不想做的):

//GUI before this one...
//code...
Thread srt = new Thread(status = new Waiter());
status.startButton.addActionListener(new ActionListener() {
  @Override
  public void actionPerformed(ActionEvent e) {
    /*
     * Code that should come after this GUI.
     */
  }
});
//Thread's run() being something like "status.setVisible(true);"
srt.start();
//"ends" here...(Initial code or GUI before this "status")

换句话说,我无法以触发主线程的“睡眠”和“唤醒”动作的方式实现 GUI 和侦听器,而不是触发实际的处理代码。


更新 2:

按照@JB_Nizet 关于 的提示SwingUtilities.invokeLater(),我仔细查看了SwingUtilities 文档,在了解了该SwingUtilities.invokeAndWait()方法的工作原理之后,我想我已经找到了如何使用Semaphore和的组合invokeAndWait()

我需要一个对多线程和/或 GUI 有更好理解的人来确认它是否是一个安全、有效的解决方案。(然后我将编辑问题并清理它,如果得到确认,请以正确的“答案格式”发布)

无论如何,这里是修改后的代码,这似乎对我有用:

public class Main_Test {

    //Semaphore:
    public static Semaphore semaphore;
    //GUIs:
    private static Waiter auth; //Represents my NTLM-authentication form.

    public static void main(String[] args) {
        try {
            semaphore = new Semaphore(1);
//          semaphore.acquire();
            auth = new Waiter() {

                @Override
                public void run() {
                    try {
                        System.out.println(Main_Test.getThread() + this.getName() + " has been created and is now running.");
                        semaphore.acquire(); //Makes main pause.
                        this.setVisible(true);
                    } catch (InterruptedException ex) {
                        Logger.getLogger(Main_Test.class.getName()).log(Level.SEVERE, null, ex);
                    }
                }
            };
            auth.jButton1.addActionListener(new ActionListener() {

                @Override
                public void actionPerformed(ActionEvent e) {
                    System.out.println(getThread() + "NTLM has been hypothetically authenticated.");
                    semaphore.release(); //Makes main continue after GUI is done.
                    auth.dispose();
                }
            });
//          semaphore.release();
            SwingUtilities.invokeAndWait(auth);
            semaphore.acquire(); //<- Where the main effectively gets paused until the permit is released.
            /*
             * GUI's run() will accquire the semaphore's permit.
             * The invokeAndWait() garantees (?) it will happen before main's acquire().
             * This causes the main to pause when trying to acquire the permit.
             * It stays paused until the actionListener release() that permit.
             */
            System.out.println(getThread() + "This message represents the processing, and should come only after the hypothetical NTLM authentication.");
        } catch (InterruptedException ex) {
            Logger.getLogger(Main_Test.class.getName()).log(Level.SEVERE, null, ex);
        } catch (InvocationTargetException ex) {
            Logger.getLogger(Main_Test.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    public static String getThread() {
        return String.format("%-32s --- ", Thread.currentThread().toString());
    }
}
4

1 回答 1

1

我不确定我是否完全理解你想要做什么,但在我看来你有一个消费者线程(主线程,等待来自事件调度线程的事件)和一个生产者线程(事件调度线程)。

实现这一点的典型方法是使用阻塞队列作为通信机制:

  • 创建阻塞队列
  • 创建您的 GUI 并将其传递给阻塞队列
  • 启动一个从队列中获取数据的循环。由于队列是阻塞的,所以主线程将被阻塞,直到队列中有东西
  • 让您的事件侦听器在 EDT 中运行,将数据发布到阻塞队列
于 2012-08-02T13:19:34.857 回答