Здесь есть одна огромная проблема:
protected void done() {
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
pDialog.dispose();
}
Метод done() рабочего вызывается в потоке EDT или в потоке диспетчеризации событий, и вы знаете, что происходит, когда вы спите в этом потоке - весь GUIидет спать и становится совершенно не отвечает.Если вы хотите отложить удаление диалогового окна и сохранить работу графического интерфейса, не делайте этого, и на самом деле никогда вызовите Thread.sleep на EDT.
Вариант 1:
Вместо этого в большинстве других тактик задержки Swing используйте, например, таймер Swing (например, код не проверен):
protected void done() {
int timerDelay = 5000;
new Timer(timerDelay, new ActionListener() {
public void actionPerformed(ActionEvent e) {
pDialog.dispose();
((Timer) e.getSource).stop();
}
}).start();
}
Если вы не знакомы с использованием таймеров Swing, ознакомьтесь с Учебником по Swing Timer
Вариант 2:
Поставьте Thread.sleep(5000) в концевашего doInBackground() метода, прямо перед return null;
Еще одна проблема: вы используете пару методов публикации / процесса, но только один раз , чтопобеждает свою цель.Возможно, вы хотели вызвать публикацию в цикле опроса while?Конечно, вы можете вызвать get() только один раз, но есть ли другой способ извлечь информацию из запущенного процесса, который вы вызываете?Если это так, то информация должна быть получена с перерывами, либо в цикле опроса while, либо с помощью какого-либо процесса, позволяющего извлечь промежуточные результаты.
Например:
import java.awt.BorderLayout;
import java.awt.Dialog.ModalityType;
import java.awt.Dimension;
import java.awt.Window;
import java.awt.event.ActionEvent;
import java.beans.*;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;
import javax.swing.*;
public class TestProgressDialog extends JPanel {
private static final long serialVersionUID = 1L;
private ProgressDialog pDialog;
private JSpinner taskNumberSpinner = new JSpinner(new SpinnerNumberModel(10, 1, 20, 1));
public TestProgressDialog() {
setPreferredSize(new Dimension(800, 650));
add(new JButton(new AbstractAction("Launch Dialog") {
private static final long serialVersionUID = 1L;
@Override
public void actionPerformed(ActionEvent e) {
Window owner = SwingUtilities.windowForComponent(TestProgressDialog.this);
String title = "Dialog";
ModalityType modal = ModalityType.MODELESS;
int numTasks = (int) taskNumberSpinner.getValue();
pDialog = new ProgressDialog(owner, title, modal, numTasks);
pDialog.pack();
pDialog.setLocationByPlatform(true);
pDialog.append("Initializing background tasks\n");
MyWorker myWorker = new MyWorker(numTasks, pDialog);
myWorker.addPropertyChangeListener(new WorkerListener(pDialog));
myWorker.execute();
pDialog.setVisible(true);
}
}));
add(new JLabel("Number of Tasks:"));
add(taskNumberSpinner);
}
private static void createAndShowGui() {
TestProgressDialog mainPanel = new TestProgressDialog();
JFrame frame = new JFrame("Test Progress Dialog");
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
frame.getContentPane().add(mainPanel);
frame.pack();
frame.setLocationByPlatform(true);
frame.setVisible(true);
}
public static void main(String[] args) {
SwingUtilities.invokeLater(() -> createAndShowGui());
}
}
interface Progressable {
void setProgress(int progress);
void append(String text);
}
class ProgressDialog extends JDialog implements Progressable {
private static final long serialVersionUID = 1L;
private JProgressBar progressBar = new JProgressBar(0, 100);
private JTextArea textArea = new JTextArea(10, 30);
private JScrollPane scrollPane = new JScrollPane(textArea);
ProgressDialog(Window owner, String title, ModalityType modal, int nunTasks) {
super(owner, title, modal);
progressBar.setStringPainted(true);
scrollPane.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_ALWAYS);
add(progressBar, BorderLayout.PAGE_START);
add(scrollPane);
}
@Override
public void append(String text) {
textArea.append(text);
}
@Override
public void setProgress(int progress) {
progressBar.setValue(progress);
}
}
class MyCallable implements Callable<String> {
private static final long MAX_DUR = 6 * 1000;
private static final long MIN_DUR = 1000;
private String text;
public MyCallable(String text) {
this.text = text;
}
public String getText() {
return text;
}
@Override
public String call() throws Exception {
// just wait some random delay and then return a String
long timeout = (long) (Math.random() * MAX_DUR + MIN_DUR);
TimeUnit.MILLISECONDS.sleep(timeout);
return text + " time out: " + timeout;
}
}
class WorkerListener implements PropertyChangeListener {
private Progressable progressable;
public WorkerListener(Progressable progressable) {
this.progressable = progressable;
}
@Override
public void propertyChange(PropertyChangeEvent evt) {
if (evt.getPropertyName() != null && evt.getPropertyName().equals("progress")) {
int progress = (int)evt.getNewValue();
progressable.setProgress(progress);
}
}
}
class MyWorker extends SwingWorker<Void, String> {
private Progressable progressable;
private List<Future<String>> futures = new ArrayList<>();
private CompletionService<String> completionService;
private int numTasks;
// private BlockingQueue<Future<String>> completionQueue;
public MyWorker(int numTasks, Progressable progressable) {
this.numTasks = numTasks;
this.progressable = progressable;
ExecutorService service = Executors.newFixedThreadPool(numTasks);
completionService = new ExecutorCompletionService<>(service);
for (int i = 0; i < numTasks; i++) {
futures.add(completionService.submit(new MyCallable("My Callable " + i)));
}
service.shutdown();
}
@Override
protected Void doInBackground() throws Exception {
while (futures.size() > 0) {
Future<String> future = completionService.take();
futures.remove(future);
int progress = (100 * (numTasks - futures.size())) / numTasks;
progress = Math.min(100, progress);
progress = Math.max(0, progress);
setProgress(progress);
if (future != null) {
publish(future.get());
}
}
return null;
}
@Override
protected void process(List<String> chunks) {
for (String chunk : chunks) {
progressable.append(chunk + "\n");
}
}
public Progressable getpDialog() {
return progressable;
}
}