以线程安全的方式使用ExecutorService和ProgressMonitor

Question

progressMonitor = new ProgressMonitor(parent, "Starting processing ...", "", 0, maxNumberProcesses+1);
progressMonitor.setProgress(0);

ExecutorService execService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()); // use all available processors at startup
execService.invokeAll(callables); // wait for all tasks to complete
execService.shutdownNow(); // free thread pool resources

class Callable implements Callable<List<String>>
{
    public List<String> call()
    {
        List<String> files = doSomeStuff();
        progressBarUpdate();
        return files;
    }
}

即；每个可调用方调用progressBarUpdate（）：

private void progressBarUpdate()
{
    if (progressMonitor != null)
    {
        Lock lock = new ReentrantLock();
        lock.lock();
        try
        {
            progressMonitor.increment();
        }
        finally
        {
            lock.unlock(); // release lock
        }
    }
}

每个doSomeStuff（）都有自己的异常处理，如果发生错误或抛出异常，则返回一个空值。这就是为什么返回类型是List，并且在这种情况下返回null的原因。调用项和它们返回的文件列表之间没有交叉，它们都维护自己的文件列表。

我发现它工作得很好,但偶尔会抛出窗体的InterruptedException：

Disposal was interrupted:
java.lang.InterruptedException
at java.lang.Object.wait(Native Method)
at java.lang.Object.wait(Object.java:503)
at java.awt.EventQueue.invokeAndWait(EventQueue.java:1263)
at java.awt.Window.doDispose(Window.java:1209)
at java.awt.Dialog.doDispose(Dialog.java:1196)
at java.awt.Window.dispose(Window.java:1147)
at javax.swing.ProgressMonitor.close(ProgressMonitor.java:311)
at javax.swing.ProgressMonitor.setProgress(ProgressMonitor.java:264)

public void setProgress(int nv) {
    if (nv >= max) {
        close();
    }
...

我修改了代码，使条件nv>=max不满足，并且在invokeAll（）之后显式调用ProgressMonitor.Close()，但我仍然不相信这样的方法是完全线程安全的。

还有谁遇到过这种情况，找到了坚如磐石的解决方案吗？

谢谢

Answer 1

如果要执行后台任务并显示进度，则应使用SwingWorker。SwingWorker有一个Progress属性，您可以监听它。它确保进度更新是在事件调度线程中完成的，而任务是在后台线程中完成的。

例如：

SwingWorker<?,?> task = ...;
final JProgressBar progressBar = new JProgressBar(0, 100);

task.addPropertyChangeListener(
        new PropertyChangeListener() {
            public  void propertyChange(PropertyChangeEvent evt) {
                 if ("progress".equals(evt.getPropertyName())) {
                     progressBar.setValue((Integer)evt.getNewValue());
            }
        }
 });

完整的示例代码在SwingWorker的javadoc中。