Replace RequestProcessor.getDefault().post() and new RequestProcessor().post() by VisualVM.getInstance().runTask()

Author: jisedlac

visualvm/application/src/org/graalvm/visualvm/application/ApplicationSupport.java

@@ -25,14 +25,13 @@
 
 package org.graalvm.visualvm.application;
 
-import org.graalvm.visualvm.application.jvm.Jvm;
 import org.graalvm.visualvm.core.datasource.descriptor.DataSourceDescriptor;
 import org.graalvm.visualvm.core.datasource.descriptor.DataSourceDescriptorFactory;
 import org.graalvm.visualvm.core.properties.PropertiesSupport;
 import org.graalvm.visualvm.host.Host;
 import org.graalvm.visualvm.host.LocalHostDescriptor;
 import java.lang.management.ManagementFactory;
-import org.openide.util.RequestProcessor;
+import org.graalvm.visualvm.core.VisualVM;
 import org.openide.windows.WindowManager;
 
 /**
@@ -57,7 +56,7 @@ Application createCurrentApplication() {
     private void initCurrentApplication() {
         WindowManager.getDefault().invokeWhenUIReady(new Runnable() {
             public void run() {
-                RequestProcessor.getDefault().post(new Runnable() {
+                VisualVM.getInstance().runTask(new Runnable() {
                     public void run() {
                         // Initialize sorting
                         DataSourceDescriptor localHostDescriptor =

visualvm/application/src/org/graalvm/visualvm/application/snapshot/ApplicationSnapshot.java

@@ -32,10 +32,10 @@
 import java.io.File;
 import javax.swing.JFileChooser;
 import javax.swing.SwingUtilities;
+import org.graalvm.visualvm.core.VisualVM;
 import org.netbeans.api.progress.ProgressHandle;
 import org.netbeans.api.progress.ProgressHandleFactory;
 import org.openide.util.NbBundle;
-import org.openide.util.RequestProcessor;
 import org.openide.windows.WindowManager;
 
 /**
@@ -80,7 +80,7 @@ public void saveAs() {
             String filePath = chooser.getSelectedFile().getAbsolutePath();
             if (!filePath.endsWith(categorySuffix)) filePath += categorySuffix;
             final File file = new File(filePath);
-            RequestProcessor.getDefault().post(new Runnable() {
+            VisualVM.getInstance().runTask(new Runnable() {
                 public void run() {
                     ProgressHandle pHandle = null;
                     try {

visualvm/application/src/org/graalvm/visualvm/application/snapshot/ApplicationSnapshotProvider.java

@@ -42,12 +42,12 @@
 import java.util.logging.Level;
 import java.util.logging.Logger;
 import javax.swing.SwingUtilities;
+import org.graalvm.visualvm.core.VisualVM;
 import org.netbeans.api.progress.ProgressHandle;
 import org.netbeans.api.progress.ProgressHandleFactory;
 import org.openide.DialogDisplayer;
 import org.openide.NotifyDescriptor;
 import org.openide.util.NbBundle;
-import org.openide.util.RequestProcessor;
 
 /**
  *
@@ -77,7 +77,7 @@ private ApplicationSnapshotProvider() {
     }
 
     void createSnapshot(final Application application, final boolean openSnapshot) {
-        RequestProcessor.getDefault().post(new Runnable() {
+        VisualVM.getInstance().runTask(new Runnable() {
             public void run() {
                 ProgressHandle pHandle = null;
                 try {
@@ -181,7 +181,7 @@ private void processApplicationSnapshotImpl(final File archive, final boolean de
                                                 final boolean openSnapshot) {
         // TODO: check if the same snapshot isn't already imported
 
-        RequestProcessor.getDefault().post(new Runnable() {
+        VisualVM.getInstance().runTask(new Runnable() {
             public void run() {
                 ProgressHandle pHandle = null;
                 try {
@@ -252,7 +252,7 @@ private void loadSnapshots() {
 
 
     void initialize() {
-        RequestProcessor.getDefault().post(new Runnable() {
+        VisualVM.getInstance().runTask(new Runnable() {
             public void run() { loadSnapshots(); }
         });
     }

visualvm/applicationviews/src/org/graalvm/visualvm/application/views/monitor/ApplicationMonitorModel.java

@@ -47,15 +47,14 @@
 import java.io.InputStream;
 import java.io.OutputStream;
 import java.lang.management.MemoryMXBean;
-import java.lang.management.OperatingSystemMXBean;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 import javax.swing.SwingUtilities;
 import javax.swing.event.ChangeEvent;
 import javax.swing.event.ChangeListener;
+import org.graalvm.visualvm.core.VisualVM;
 import org.openide.util.NbBundle;
-import org.openide.util.RequestProcessor;
 
 
 /**
@@ -226,7 +225,7 @@ public synchronized void initialize() {
     public void registerCpuChartSupport(final SimpleXYChartSupport cpuChartSupport) {
         this.cpuChartSupport = cpuChartSupport;
         if (cpuChartSupport != null && source instanceof Snapshot)
-            RequestProcessor.getDefault().post(new Runnable() {
+            VisualVM.getInstance().runTask(new Runnable() {
                 public void run() {
                     File file = new File(source.getStorage().getDirectory(), CPU_CHART_STORAGE);
                     if (file.isFile()) loadChartSupport(cpuChartSupport, file);
@@ -237,7 +236,7 @@ public void run() {
     public void registerHeapChartSupport(final SimpleXYChartSupport heapChartSupport) {
         this.heapChartSupport = heapChartSupport;
         if (heapChartSupport != null && source instanceof Snapshot)
-            RequestProcessor.getDefault().post(new Runnable() {
+            VisualVM.getInstance().runTask(new Runnable() {
                 public void run() {
                     File file = new File(source.getStorage().getDirectory(), HEAP_CHART_STORAGE);
                     if (file.isFile()) loadChartSupport(heapChartSupport, file);
@@ -248,7 +247,7 @@ public void run() {
     public void registerPermGenChartSupport(final SimpleXYChartSupport permgenChartSupport) {
         this.permGenChartSupport = permgenChartSupport;
         if (permGenChartSupport != null && source instanceof Snapshot)
-            RequestProcessor.getDefault().post(new Runnable() {
+            VisualVM.getInstance().runTask(new Runnable() {
                 public void run() {
                     File file = new File(source.getStorage().getDirectory(), PERMGEN_CHART_STORAGE);
                     if (file.isFile()) loadChartSupport(permGenChartSupport, file);
@@ -259,7 +258,7 @@ public void run() {
     public void registerClassesChartSupport(final SimpleXYChartSupport classesChartSupport) {
         this.classesChartSupport = classesChartSupport;
         if (classesChartSupport != null && source instanceof Snapshot)
-            RequestProcessor.getDefault().post(new Runnable() {
+            VisualVM.getInstance().runTask(new Runnable() {
                 public void run() {
                     File file = new File(source.getStorage().getDirectory(), CLASSES_CHART_STORAGE);
                     if (file.isFile()) loadChartSupport(classesChartSupport, file);
@@ -270,7 +269,7 @@ public void run() {
     public void registerThreadsChartSupport(final SimpleXYChartSupport threadsChartSupport) {
         this.threadsChartSupport = threadsChartSupport;
         if (threadsChartSupport != null && source instanceof Snapshot)
-            RequestProcessor.getDefault().post(new Runnable() {
+            VisualVM.getInstance().runTask(new Runnable() {
                 public void run() {
                     File file = new File(source.getStorage().getDirectory(), THREADS_CHART_STORAGE);
                     if (file.isFile()) loadChartSupport(threadsChartSupport, file);

visualvm/applicationviews/src/org/graalvm/visualvm/application/views/threads/ApplicationThreadsView.java

@@ -68,7 +68,6 @@
 import org.graalvm.visualvm.lib.profiler.api.ProfilerDialogs;
 import org.openide.util.ImageUtilities;
 import org.openide.util.NbBundle;
-import org.openide.util.RequestProcessor;
 import org.openide.util.WeakListeners;
 
 /**
@@ -185,8 +184,6 @@ public void run() {
 
     private static class MasterViewSupport extends JPanel implements DataRemovedListener<Application>, PropertyChangeListener {
 
-        private static RequestProcessor worker = null;
-
         private Application application;
         private HTMLTextArea area;
         private HTMLTextArea alertArea;
@@ -298,11 +295,6 @@ private void updateThreadsCounts(int liveThreads, int daemonThreads) {
             area.select(selStart, selEnd);
         }
 
-        private static synchronized RequestProcessor getWorker() {
-            if (worker == null) worker = new RequestProcessor("ThreadsWorker", 1); // NOI18N
-            return worker;
-        }
-
     }
 
     // --- Timeline ------------------------------------------------------------

visualvm/applicationviews/src/org/graalvm/visualvm/application/views/threads/ThreadMXBeanDataManager.java

@@ -35,10 +35,10 @@
 import java.util.Set;
 import java.util.logging.Logger;
 import javax.swing.SwingUtilities;
+import org.graalvm.visualvm.core.VisualVM;
 import org.graalvm.visualvm.lib.jfluid.client.MonitoredData;
 import org.graalvm.visualvm.lib.jfluid.global.CommonConstants;
 import org.graalvm.visualvm.lib.jfluid.wireprotocol.MonitoredNumbersResponse;
-import org.openide.util.RequestProcessor;
 
 /**
  *
@@ -72,7 +72,7 @@ void refreshThreadsAsync() {
             if (refreshRunning) return;
             refreshRunning = true;
         }
-        RequestProcessor.getDefault().post(new Runnable() {
+        VisualVM.getInstance().runTask(new Runnable() {
             public void run() {
                 long[] oldDeadlockThreadIds = deadlockThreadIds;
 

visualvm/appui/src/org/graalvm/visualvm/modules/appui/about/AboutDialogControls.java

@@ -43,11 +43,11 @@
 import javax.swing.JOptionPane;
 import javax.swing.JPanel;
 import javax.swing.SwingUtilities;
+import org.graalvm.visualvm.core.VisualVM;
 import org.netbeans.api.progress.ProgressHandle;
 import org.netbeans.api.progress.ProgressHandleFactory;
 import org.openide.awt.Mnemonics;
 import org.openide.util.NbBundle;
-import org.openide.util.RequestProcessor;
 import org.openide.windows.WindowManager;
 
 /**
@@ -245,7 +245,7 @@ private void saveFileAs(final File file) {
             final File copy = chooser.getSelectedFile();
 //            if (copy.isFile()) // TODO: show a confirmation dialog for already existing file
             lastLogfileSave = copy.getAbsolutePath();
-            RequestProcessor.getDefault().post(new Runnable() {
+            VisualVM.getInstance().runTask(new Runnable() {
                 public void run() {
                     ProgressHandle pHandle = null;
                     try {

visualvm/core/src/org/graalvm/visualvm/core/snapshot/SnapshotsSupport.java

@@ -33,12 +33,12 @@
 import java.util.Date;
 import javax.swing.JFileChooser;
 import javax.swing.SwingUtilities;
+import org.graalvm.visualvm.core.VisualVM;
 import org.netbeans.api.progress.ProgressHandle;
 import org.netbeans.api.progress.ProgressHandleFactory;
 import org.graalvm.visualvm.lib.profiler.api.ProfilerDialogs;
 import org.openide.util.ImageUtilities;
 import org.openide.util.NbBundle;
-import org.openide.util.RequestProcessor;
 import org.openide.windows.WindowManager;
 
 /**
@@ -86,7 +86,7 @@ public void saveAs(final Snapshot snapshot, String dialogTitle) {
                 String filePath = chooser.getSelectedFile().getAbsolutePath();
                 if (!filePath.endsWith(categorySuffix)) filePath += categorySuffix;
                 final File copy = new File(filePath);
-                RequestProcessor.getDefault().post(new Runnable() {
+                VisualVM.getInstance().runTask(new Runnable() {
                     public void run() {
                         ProgressHandle pHandle = null;
                         try {

visualvm/core/src/org/graalvm/visualvm/core/ui/actions/LoadRecentSnapshot.java

@@ -36,12 +36,12 @@
 import javax.swing.JMenuItem;
 import javax.swing.SwingUtilities;
 import javax.swing.filechooser.FileFilter;
+import org.graalvm.visualvm.core.VisualVM;
 import org.graalvm.visualvm.lib.profiler.api.ProfilerDialogs;
 import org.openide.awt.Mnemonics;
 import org.openide.awt.StatusDisplayer;
 import org.openide.util.NbBundle;
 import org.openide.util.NbPreferences;
-import org.openide.util.RequestProcessor;
 import org.openide.util.actions.Presenter;
 
 /**
@@ -163,7 +163,7 @@ protected void fireStateChanged() {
 
         @Override
         protected void fireActionPerformed(ActionEvent e) {
-            RequestProcessor.getDefault().post(new Runnable() {
+            VisualVM.getInstance().runTask(new Runnable() {
                 public void run() {
                     if (file.exists()) {
                         List<SnapshotCategory> categories = RegisteredSnapshotCategories.sharedInstance().getOpenSnapshotCategories();

visualvm/coredump/src/org/graalvm/visualvm/coredump/impl/CoreDumpProvider.java

@@ -48,13 +48,13 @@
 import javax.swing.JPanel;
 import javax.swing.JScrollPane;
 import javax.swing.SwingUtilities;
+import org.graalvm.visualvm.core.VisualVM;
 import org.netbeans.api.progress.ProgressHandle;
 import org.netbeans.api.progress.ProgressHandleFactory;
 import org.graalvm.visualvm.lib.ui.SwingWorker;
 import org.openide.DialogDisplayer;
 import org.openide.NotifyDescriptor;
 import org.openide.util.NbBundle;
-import org.openide.util.RequestProcessor;
 import org.openide.windows.WindowManager;
 
 /**
@@ -116,7 +116,7 @@ protected void done() {
     }
 
     static void createCoreDump(final String coreDumpFile, final String displayName, final String jdkHome, final boolean deleteCoreDump) {
-        RequestProcessor.getDefault().post(new Runnable() {
+        VisualVM.getInstance().runTask(new Runnable() {
             public void run() {
                 createCoreDumpImpl(coreDumpFile, displayName, jdkHome, deleteCoreDump);
             }
@@ -237,7 +237,7 @@ public boolean accept(File dir, String name) {
     }
 
     private static void notifyUnresolvedCoreDumps(final Set<File> unresolvedCoreDumpsF, final Set<String> unresolvedCoreDumpsS) {
-        RequestProcessor.getDefault().post(new Runnable() {
+        VisualVM.getInstance().runTask(new Runnable() {
             public void run() {
                 JPanel messagePanel = new JPanel(new BorderLayout(5, 5));
                 messagePanel.add(new JLabel(NbBundle.getMessage(CoreDumpProvider.class, "MSG_Unresolved_CoreDumps")), BorderLayout.NORTH); // NOI18N
@@ -265,7 +265,7 @@ public static void register() {
         final CoreDumpProvider provider = new CoreDumpProvider();
         WindowManager.getDefault().invokeWhenUIReady(new Runnable() {
             public void run() {
-                RequestProcessor.getDefault().post(new Runnable() {
+                VisualVM.getInstance().runTask(new Runnable() {
                     public void run() {
                         provider.initPersistedCoreDumps();
                     }