依次执行SwingWorker (Synchronize SwingWorker s)

Question

我想运行一个SwingWorker接一个结束。我的 2 个线程在同一个 class 上的不同方法中，我想按照另一个 class 的顺序使用它们，如下所示：

int x = runn.runProcessStart();
int y = runn. runProcessEnd();

工人CLASS

public class MyClass {

    private int counter = 0;

    public int runProcessStart() {
        int result = 0;

        SwingWorker<Integer, String> worker = new SwingWorker<Integer, String>() {
            @Override
            protected Integer doInBackground() throws Exception {
                for (int i = 0; i < 10; i++) {
                    publish("start message number " + counter++);
                    Thread.sleep(500);
                }

                return 0;
            }

            @Override
            protected void process(List<String> chunks) {
                // this is called on the Swing event thread
                for (String text : chunks) {
                    Sysem.out.println(text);
                }
            }
        };

        worker.execute();

        if (worker.getState() == SwingWorker.StateValue.DONE) {
            try {
                result = worker.get();
            } catch (ExecutionException | InterruptedException ex) {
                Sysem.out.println(ex.getMEssage());
            }

        }

        return result;
    }

    public int runProcessEnd() {
        int result = 0;

        SwingWorker<Integer, String> worker = new SwingWorker<Integer, String>() {
            @Override
            protected Integer doInBackground() throws Exception {
                for (int i = 0; i < 10; i++) {
                    publish("end message number " + counter++);
                    Thread.sleep(500);
                }

                return 0;
            }

            @Override
            protected void process(List<String> chunks) {
                // this is called on the Swing event thread
                for (String text : chunks) {
                    Sysem.out.println(text);
                }
            }
        };

        worker.execute();

        if (worker.getState() == SwingWorker.StateValue.DONE) {
            try {
                result = worker.get();
            } catch (ExecutionException | InterruptedException ex) {
                Sysem.out.println(ex.getMEssage());
            }

        }

        return result;
    }

}

我该怎么做？

另一个问题是...我使用 .get() 检索 doInBackground 进程的值的方式是否正确？

Answer 1

使用 SwingWorker#done 方法，如下面的 mcve 所示：

import java.awt.BorderLayout;
import java.util.List;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.SwingWorker;

public class MyClass {

    private int counter = 0;
    private JLabel showCounter;
    private JButton start;

    public MyClass() {

        JFrame window = new JFrame();
        window.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

        start = new JButton("Start");
        start.addActionListener(e -> runProcessStart());
        window.add(start, BorderLayout.PAGE_START);

        showCounter = new JLabel(String.valueOf("Click button to start" ));
        window.add(showCounter, BorderLayout.PAGE_END);
        window.pack();
        window.setVisible(true);
    }

    public void runProcessStart() {

        start.setEnabled(false);

        SwingWorker<Void, Integer> worker = new SwingWorker<Void, Integer>() {
            @Override
            protected Void doInBackground() throws Exception {
                for (int i = 0; i < 10; i++) {
                    publish(counter++);
                    Thread.sleep(2000);
                }

                return null;
            }

            @Override
            protected void process(List<Integer> chunks) {
                for (int i : chunks) {
                    showCounter.setText("Process Start running "+ i);
                }
            }

            @Override
            protected void done() {
                showCounter.setText("Process Start finished");
                runProcessEnd();
            }
        };

        worker.execute();
    }

    public void runProcessEnd() {

        SwingWorker<Void, Integer> worker = new SwingWorker<Void, Integer>() {
            @Override
            protected Void doInBackground() throws Exception {
                for (int i = 0; i < 10; i++) {
                    Thread.sleep(2000);
                    publish(counter--);
                }

                return null;
            }

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

                 for (int i : chunks) {
                     showCounter.setText("Process End running "+ i);
                 }
            }

            @Override
            protected void done() {
                start.setEnabled(true);
                showCounter.setText("All done");
            }
        };

        worker.execute();
    }

    public static void main(String[] args) {
        new MyClass();
    }
}

请注意 return 由

编辑的值

int x = runn.runProcessStart();
int y = runn.runProcessEnd();

在您的代码中，可能不是您所期望的，因为 runProcessStart() 和 runProcessEnd() return 在 SwingWorker 结束之前。

依次执行SwingWorker (Synchronize SwingWorker s)

Execute SwingWorker after another (Synchronize SwingWorker s)

java

swing

multithreading

swingworker