import java.util.Vector;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
+import java.util.concurrent.Semaphore;
import javax.swing.DefaultDesktopManager;
import javax.swing.DesktopManager;
* single thread that handles display of dialogs to user.
*/
ExecutorService dialogExecutor=Executors.newSingleThreadExecutor();
+ /**
+ * flag indicating if dialogExecutor should try to acquire a permit
+ */
+ private volatile boolean dialogPause=true;
+ /**
+ * pause the queue
+ */
+ private java.util.concurrent.Semaphore block=new Semaphore(0);
/**
* add another dialog thread to the queue
{
public void run()
{
+ if (dialogPause) {
+ try { block.acquire(); } catch (InterruptedException x){};
+ }
+ if (instance==null)
+ {
+ return;
+ }
try
{
SwingUtilities.invokeAndWait(prompter);
});
}
+ public void startDialogQueue()
+ {
+ // set the flag so we don't pause waiting for another permit and semaphore the current task to begin
+ dialogPause=false;
+ block.release();
+ }
}