类javax.swing.SwingWorker源码实例Demo

下面列出了怎么用javax.swing.SwingWorker的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: dragonwell8_jdk   文件: XMBeanAttributes.java
private void refreshAttributes(final boolean stopCellEditing) {
    SwingWorker<Void,Void> sw = new SwingWorker<Void,Void>() {

       @Override
       protected Void doInBackground() throws Exception {
           SnapshotMBeanServerConnection mbsc =
           mbeansTab.getSnapshotMBeanServerConnection();
           mbsc.flush();
           return null;
       }

       @Override
       protected void done() {
           try {
               get();
               if (stopCellEditing) stopCellEditing();
               loadAttributes(mbean, mbeanInfo);
           } catch (Exception x) {
               if (JConsole.isDebug()) {
                   x.printStackTrace();
               }
           }
       }
    };
    mbeansTab.workerAdd(sw);
}
 
源代码2 项目: ghidra   文件: CachingSwingWorkerTest.java
private void disasbleTimerUsage() {
	AccumulativeRunnable<Runnable> nonTimerAccumulativeRunnable =
		new AccumulativeRunnable<Runnable>() {
			@Override
			protected void run(List<Runnable> args) {
				for (Runnable runnable : args) {
					runnable.run();
				}
			}
		};

	Object key = getInstanceField("DO_SUBMIT_KEY", SwingWorker.class);

	AppContext appContext = AppContext.getAppContext();
	appContext.put(key, nonTimerAccumulativeRunnable);
}
 
源代码3 项目: jdk8u-dev-jdk   文件: XMBeanAttributes.java
private void refreshAttributes(final boolean stopCellEditing) {
    SwingWorker<Void,Void> sw = new SwingWorker<Void,Void>() {

       @Override
       protected Void doInBackground() throws Exception {
           SnapshotMBeanServerConnection mbsc =
           mbeansTab.getSnapshotMBeanServerConnection();
           mbsc.flush();
           return null;
       }

       @Override
       protected void done() {
           try {
               get();
               if (stopCellEditing) stopCellEditing();
               loadAttributes(mbean, mbeanInfo);
           } catch (Exception x) {
               if (JConsole.isDebug()) {
                   x.printStackTrace();
               }
           }
       }
    };
    mbeansTab.workerAdd(sw);
}
 
源代码4 项目: hottub   文件: XSheet.java
/**
 * Unsubscribe button action.
 */
private void unregisterListener() {
    new SwingWorker<Boolean, Void>() {
        @Override
        public Boolean doInBackground() {
            return mbeanNotifications.unregisterListener(currentNode);
        }
        @Override
        protected void done() {
            try {
                if (get()) {
                    updateNotifications();
                    validate();
                }
            } catch (Exception e) {
                Throwable t = Utils.getActualException(e);
                if (JConsole.isDebug()) {
                    System.err.println("Problem removing listener");
                    t.printStackTrace();
                }
                showErrorDialog(t.getMessage(),
                        Messages.PROBLEM_REMOVING_LISTENER);
            }
        }
    }.execute();
}
 
源代码5 项目: PyramidShader   文件: MainWindow.java
private void executeOperatorInWorker(ThreadedGridOperator op, String message) {
    final OperatorWorker operatorWorker = new OperatorWorker(progressPanel,
            model.getGrid(), op);
    operatorWorker.resetProgressGUI(true);
    operatorWorker.setMessage(message);
    operatorWorker.addPropertyChangeListener(
            new PropertyChangeListener() {
        @Override
        public void propertyChange(PropertyChangeEvent event) {
            if ("state".equals(event.getPropertyName())
                    && SwingWorker.StateValue.DONE == event.getNewValue()) {
                if (operatorWorker.isCancelled() == false) {
                    model.setGrid(operatorWorker.getResultGrid());
                    settingsDialog.gridChanged();
                }
            }
        }
    });
    gridWorkerManager.start(operatorWorker, true, true);
}
 
源代码6 项目: jdk8u-jdk   文件: bug6432565.java
public static void main(String[] args) throws Exception {
    Toolkit.getDefaultToolkit().getSystemEventQueue().push(new EventProcessor());

    SwingWorker<Void, CharSequence> swingWorker =
        new SwingWorker<Void,CharSequence>() {
            @Override
            protected Void doInBackground() {
                publish(new String[] {"hello"});
                publish(new StringBuilder("world"));
                return null;
            }
            @Override
            protected void done() {
                isDone.set(true);
            }
        };
    swingWorker.execute();

    while (! isDone.get()) {
        Thread.sleep(100);
    }
    if (throwable.get() instanceof ArrayStoreException) {
        throw new RuntimeException("Test failed");
    }
}
 
源代码7 项目: jdk8u-jdk   文件: XMBeanAttributes.java
private void refreshAttributes(final boolean stopCellEditing) {
    SwingWorker<Void,Void> sw = new SwingWorker<Void,Void>() {

       @Override
       protected Void doInBackground() throws Exception {
           SnapshotMBeanServerConnection mbsc =
           mbeansTab.getSnapshotMBeanServerConnection();
           mbsc.flush();
           return null;
       }

       @Override
       protected void done() {
           try {
               get();
               if (stopCellEditing) stopCellEditing();
               loadAttributes(mbean, mbeanInfo);
           } catch (Exception x) {
               if (JConsole.isDebug()) {
                   x.printStackTrace();
               }
           }
       }
    };
    mbeansTab.workerAdd(sw);
}
 
源代码8 项目: openjdk-8-source   文件: XSheet.java
/**
 * Unsubscribe button action.
 */
private void unregisterListener() {
    new SwingWorker<Boolean, Void>() {
        @Override
        public Boolean doInBackground() {
            return mbeanNotifications.unregisterListener(currentNode);
        }
        @Override
        protected void done() {
            try {
                if (get()) {
                    updateNotifications();
                    validate();
                }
            } catch (Exception e) {
                Throwable t = Utils.getActualException(e);
                if (JConsole.isDebug()) {
                    System.err.println("Problem removing listener");
                    t.printStackTrace();
                }
                showErrorDialog(t.getMessage(),
                        Messages.PROBLEM_REMOVING_LISTENER);
            }
        }
    }.execute();
}
 
源代码9 项目: android-classyshark   文件: ClassySharkPanel.java
private void readMappingFile(final File resultFile) {
    SwingWorker<Void, Void> worker = new SwingWorker<Void, Void>() {
        private TokensMapper reverseMappings;

        @Override
        protected Void doInBackground() throws Exception {
            reverseMappings = silverGhost.readMappingFile(resultFile);
            return null;
        }

        protected void done() {
            silverGhost.addMappings(reverseMappings);
        }
    };

    worker.execute();
}
 
源代码10 项目: openjdk-jdk8u   文件: XMBeanAttributes.java
private void refreshAttributes(final boolean stopCellEditing) {
    SwingWorker<Void,Void> sw = new SwingWorker<Void,Void>() {

       @Override
       protected Void doInBackground() throws Exception {
           SnapshotMBeanServerConnection mbsc =
           mbeansTab.getSnapshotMBeanServerConnection();
           mbsc.flush();
           return null;
       }

       @Override
       protected void done() {
           try {
               get();
               if (stopCellEditing) stopCellEditing();
               loadAttributes(mbean, mbeanInfo);
           } catch (Exception x) {
               if (JConsole.isDebug()) {
                   x.printStackTrace();
               }
           }
       }
    };
    mbeansTab.workerAdd(sw);
}
 
源代码11 项目: openjdk-8   文件: XSheet.java
/**
 * Unsubscribe button action.
 */
private void unregisterListener() {
    new SwingWorker<Boolean, Void>() {
        @Override
        public Boolean doInBackground() {
            return mbeanNotifications.unregisterListener(currentNode);
        }
        @Override
        protected void done() {
            try {
                if (get()) {
                    updateNotifications();
                    validate();
                }
            } catch (Exception e) {
                Throwable t = Utils.getActualException(e);
                if (JConsole.isDebug()) {
                    System.err.println("Problem removing listener");
                    t.printStackTrace();
                }
                showErrorDialog(t.getMessage(),
                        Messages.PROBLEM_REMOVING_LISTENER);
            }
        }
    }.execute();
}
 
源代码12 项目: blog   文件: SwingWorkerPropertyChangeAdapter.java
@Override
public void propertyChange(PropertyChangeEvent evt) {
	String propertyName = evt.getPropertyName();
	if ("state".equals(propertyName)) {
		StateValue state = (StateValue) evt.getNewValue();
		switch (state) {
		case PENDING:
		case STARTED:
			started();
			break;
		case DONE:
			SwingWorker<?, ?> future = (SwingWorker<?, ?>) evt.getSource();
			boolean cancelled = future.isCancelled();
			done(cancelled);
		}
	}
}
 
源代码13 项目: openjdk-8-source   文件: XMBeanAttributes.java
private void refreshAttributes(final boolean stopCellEditing) {
    SwingWorker<Void,Void> sw = new SwingWorker<Void,Void>() {

       @Override
       protected Void doInBackground() throws Exception {
           SnapshotMBeanServerConnection mbsc =
           mbeansTab.getSnapshotMBeanServerConnection();
           mbsc.flush();
           return null;
       }

       @Override
       protected void done() {
           try {
               get();
               if (stopCellEditing) stopCellEditing();
               loadAttributes(mbean, mbeanInfo);
           } catch (Exception x) {
               if (JConsole.isDebug()) {
                   x.printStackTrace();
               }
           }
       }
    };
    mbeansTab.workerAdd(sw);
}
 
源代码14 项目: hottub   文件: XMBeanAttributes.java
private void refreshAttributes(final boolean stopCellEditing) {
    SwingWorker<Void,Void> sw = new SwingWorker<Void,Void>() {

       @Override
       protected Void doInBackground() throws Exception {
           SnapshotMBeanServerConnection mbsc =
           mbeansTab.getSnapshotMBeanServerConnection();
           mbsc.flush();
           return null;
       }

       @Override
       protected void done() {
           try {
               get();
               if (stopCellEditing) stopCellEditing();
               loadAttributes(mbean, mbeanInfo);
           } catch (Exception x) {
               if (JConsole.isDebug()) {
                   x.printStackTrace();
               }
           }
       }
    };
    mbeansTab.workerAdd(sw);
}
 
源代码15 项目: jdk8u-jdk   文件: bug6432565.java
public static void main(String[] args) throws Exception {
    Toolkit.getDefaultToolkit().getSystemEventQueue().push(new EventProcessor());

    SwingWorker<Void, CharSequence> swingWorker =
        new SwingWorker<Void,CharSequence>() {
            @Override
            protected Void doInBackground() {
                publish(new String[] {"hello"});
                publish(new StringBuilder("world"));
                return null;
            }
            @Override
            protected void done() {
                isDone.set(true);
            }
        };
    swingWorker.execute();

    while (! isDone.get()) {
        Thread.sleep(100);
    }
    if (throwable.get() instanceof ArrayStoreException) {
        throw new RuntimeException("Test failed");
    }
}
 
源代码16 项目: openjdk-jdk8u-backup   文件: bug6432565.java
public static void main(String[] args) throws Exception {
    Toolkit.getDefaultToolkit().getSystemEventQueue().push(new EventProcessor());

    SwingWorker<Void, CharSequence> swingWorker =
        new SwingWorker<Void,CharSequence>() {
            @Override
            protected Void doInBackground() {
                publish(new String[] {"hello"});
                publish(new StringBuilder("world"));
                return null;
            }
            @Override
            protected void done() {
                isDone.set(true);
            }
        };
    swingWorker.execute();

    while (! isDone.get()) {
        Thread.sleep(100);
    }
    if (throwable.get() instanceof ArrayStoreException) {
        throw new RuntimeException("Test failed");
    }
}
 
源代码17 项目: hottub   文件: bug6432565.java
public static void main(String[] args) throws Exception {
    Toolkit.getDefaultToolkit().getSystemEventQueue().push(new EventProcessor());

    SwingWorker<Void, CharSequence> swingWorker =
        new SwingWorker<Void,CharSequence>() {
            @Override
            protected Void doInBackground() {
                publish(new String[] {"hello"});
                publish(new StringBuilder("world"));
                return null;
            }
            @Override
            protected void done() {
                isDone.set(true);
            }
        };
    swingWorker.execute();

    while (! isDone.get()) {
        Thread.sleep(100);
    }
    if (throwable.get() instanceof ArrayStoreException) {
        throw new RuntimeException("Test failed");
    }
}
 
源代码18 项目: openjdk-jdk9   文件: XSheet.java
/**
 * Unsubscribe button action.
 */
private void unregisterListener() {
    new SwingWorker<Boolean, Void>() {
        @Override
        public Boolean doInBackground() {
            return mbeanNotifications.unregisterListener(currentNode);
        }
        @Override
        protected void done() {
            try {
                if (get()) {
                    updateNotifications();
                    validate();
                }
            } catch (Exception e) {
                Throwable t = Utils.getActualException(e);
                if (JConsole.isDebug()) {
                    System.err.println("Problem removing listener");
                    t.printStackTrace();
                }
                showErrorDialog(t.getMessage(),
                        Messages.PROBLEM_REMOVING_LISTENER);
            }
        }
    }.execute();
}
 
源代码19 项目: visualvm   文件: JConsolePluginWrapper.java
VMPanel(Application application, JConsolePluginWrapper wrapper, ProxyClient proxyClient) {
    this.application = application;
    this.proxyClient = proxyClient;
    plugins = new LinkedHashMap<JConsolePlugin, SwingWorker<?, ?>>();
    for (JConsolePlugin p : wrapper.getPlugins()) {
        p.setContext(proxyClient);
        plugins.put(p, null);
    }
    // Start listening to connection state events
    //
    proxyClient.addPropertyChangeListener(this);
}
 
/**
 *
 * @param loadDataTask the value of loadRawDataPropertyChangeListener
 * @param usingFullPropagation the value of usingFullPropagation
 * @param leftShadeCount the value of leftShadeCount
 * @param ignoreFirstFractions the value of ignoreFirstFractions
 * @param inLiveMode the value of inLiveMode
 */
@Override
public void getAndLoadRawIntensityDataFile(SwingWorker loadDataTask, boolean usingFullPropagation, int leftShadeCount, int ignoreFirstFractions, boolean inLiveMode) {

    if (rawDataFile != null) {
        // create fractions from raw data and perform corrections and calculate ratios
         tripoliFractions = loadRawDataFile(loadDataTask, usingFullPropagation, leftShadeCount, ignoreFirstFractions, inLiveMode);
    }
}
 
源代码21 项目: dragonwell8_jdk   文件: ExceptionSafePlugin.java
@Override
public SwingWorker<?, ?> newSwingWorker() {
    try {
        return plugin.newSwingWorker();
    } catch (RuntimeException e) {
        handleException(e);
    }
    return null;
}
 
源代码22 项目: importer-exporter   文件: MapWindow.java
public void setBoundingBox(final BoundingBox bbox) {
	new SwingWorker<ValidationResult, Void>() {
		protected ValidationResult doInBackground() throws Exception {
			return validator.validate(bbox);
		}

		protected void done() {
			try {
				switch (get()) {
				case CANCEL:
					dispose();
					break;
				case SKIP:
				case OUT_OF_RANGE:
				case NO_AREA:
					clearBoundingBox();
					break;
				case INVISIBLE:
					clearBoundingBox();
					indicateInvisibleBoundingBox(bbox);
					break;
				default:
					minX.setValue(bbox.getLowerCorner().getX());
					minY.setValue(bbox.getLowerCorner().getY());
					maxX.setValue(bbox.getUpperCorner().getX());
					maxY.setValue(bbox.getUpperCorner().getY());
					showBoundingBox();
				}
			} catch (InterruptedException | ExecutionException e) {
				//
			}
		}
	}.execute();
}
 
源代码23 项目: ghidra   文件: CachingSwingWorker.java
private void blockSwingWithProgressDialog(final SwingWorker<T, Object> localWorker) {
	if (!localWorker.isDone()) {

		TaskDialog dialog = new SwingWorkerTaskDialog(name, hasProgress, localWorker);
		taskMonitor.setBlockingMonitor(dialog);
		localWorker.addPropertyChangeListener(new SwingWorkerCompletionWaiter(dialog));
		dialog.show(taskDialogDelay);
	}
}
 
源代码24 项目: ghidra   文件: CachingSwingWorker.java
@Override
public void propertyChange(PropertyChangeEvent event) {
	if ("state".equals(event.getPropertyName()) &&
		SwingWorker.StateValue.DONE == event.getNewValue()) {
		dialog.close();
	}
}
 
源代码25 项目: jdk8u-jdk   文件: ExceptionSafePlugin.java
public void executeSwingWorker(SwingWorker<?, ?> sw) {
    try {
        sw.execute();
    } catch (RuntimeException e) {
        handleException(e);
    }
}
 
源代码26 项目: beast-mcmc   文件: TreesTableModel.java
private void loadTreeFile(final File file, final int row) {

		frame.setBusy();
		SwingWorker<Void, Void> worker = new SwingWorker<Void, Void>() {

			// Executed in background thread
			public Void doInBackground() {

				try {

					Tree tree = Utils.importTreeFromFile(file);
					tree.setId(file.getName());

					setRow(row, new TreesTableRecord(tree.getId(), tree));

				} catch (Exception e) {
					Utils.handleException(e);
				}// END: try-catch block

				return null;
			}// END: doInBackground()

			// Executed in event dispatch thread
			public void done() {
				frame.setIdle();
				frame.fireTaxaChanged();
			}// END: done
		};

		worker.execute();

	}
 
源代码27 项目: TencentKona-8   文件: XSheet.java
/**
 * Subscribe button action.
 */
private void registerListener() {
    new SwingWorker<Void, Void>() {
        @Override
        public Void doInBackground()
                throws InstanceNotFoundException, IOException {
            mbeanNotifications.registerListener(currentNode);
            return null;
        }
        @Override
        protected void done() {
            try {
                get();
                updateNotifications();
                validate();
            } catch (Exception e) {
                Throwable t = Utils.getActualException(e);
                if (JConsole.isDebug()) {
                    System.err.println("Problem adding listener");
                    t.printStackTrace();
                }
                showErrorDialog(t.getMessage(),
                        Messages.PROBLEM_ADDING_LISTENER);
            }
        }
    }.execute();
}
 
/**
 *
 * @param loadDataTask the value of loadRawDataPropertyChangeListener
 * @param usingFullPropagation the value of usingFullPropagation
 * @param leftShadeCount the value of leftShadeCount
 * @param ignoreFirstFractions the value of ignoreFirstFractions
 * @param inLiveMode the value of inLiveMode
 */
@Override
public void getAndLoadRawIntensityDataFile(SwingWorker loadDataTask, boolean usingFullPropagation, int leftShadeCount, int ignoreFirstFractions, boolean inLiveMode) {

    if (rawDataFile != null) {
        // create fractions from raw data and perform corrections and calculate ratios
        tripoliFractions = loadRawDataFile(loadDataTask, usingFullPropagation, leftShadeCount, ignoreFirstFractions, inLiveMode);
    }
}
 
源代码29 项目: MtgDesktopCompanion   文件: HelpCompononent.java
private void loadDoc()
{
	
	if(isVisible())
		ThreadManager.getInstance().runInEdt(new SwingWorker<Document,Void>() {
			@Override
			protected void done() {
				try {
					
					Document d= get();
					int width = (int)getSize().getWidth();
					
					if(width<=0)
						width=450;
					
					d.select("img").attr("width", String.valueOf(width));
					pane.setText(d.html().replace("$USER_HOME", SystemUtils.USER_HOME));
				} catch (Exception e) {
					logger.error("error loading help",e);
					pane.setText(e.getLocalizedMessage());
				} 
			}
			
			@Override
			protected Document doInBackground() throws Exception {
				if(plug.getDocumentation().getContentType().equals(FORMAT_NOTIFICATION.MARKDOWN))
					return URLTools.extractMarkDownAsDocument(plug.getDocumentation().getUrl());
				else
					return URLTools.extractHtml(plug.getDocumentation().getUrl());
			}
		}, "Loading doc for "+ plug);
}
 
源代码30 项目: jdk8u60   文件: ExceptionSafePlugin.java
@Override
public SwingWorker<?, ?> newSwingWorker() {
    try {
        return plugin.newSwingWorker();
    } catch (RuntimeException e) {
        handleException(e);
    }
    return null;
}
 
 类所在包
 同包方法