import org.cytoscape.work.Task; //导入依赖的package包/类
private void startTask(Task task)
{
	Task updateTask = new AbstractTask() {
		
		@Override
		public void run(TaskMonitor taskMonitor) throws Exception {
			updateContents();				
		}
	};
	TaskManager<?,?> mgr = registrar.getService(TaskManager.class);
	mgr.execute(new TaskIterator(task, updateTask));
}
 

import org.cytoscape.work.Task; //导入依赖的package包/类
@Override
public void actionPerformed(ActionEvent event) {
	Optional<AnnotationSet> as = modelManager.getActiveNetworkViewSet().flatMap(NetworkViewSet::getActiveAnnotationSet);
	if(as.isPresent()) {
		List<FileChooserFilter> filter = Collections.singletonList(new FileChooserFilter("txt Files", "txt"));
		File file = fileUtil.getFile(jframeProvider.get(), TITLE, FileUtil.SAVE, filter);
		if(file != null) {
			Task exportTask = new ExportTask(as.get(), file);
			dialogTaskManager.execute(new TaskIterator(exportTask));
		}
	}
}
 

import org.cytoscape.work.Task; //导入依赖的package包/类
public static Collector<Task, ?, TaskIterator> taskIterator() {
	return Collector.of(
			TaskIterator::new, 
			TaskIterator::append, 
			(left, right) -> { left.append(right); return left; }, 
			Collector.Characteristics.IDENTITY_FINISH);
}
 

import org.cytoscape.work.Task; //导入依赖的package包/类
public static Task taskMessage(String message) {
	return new AbstractTask() {
		@Override
		public void run(TaskMonitor taskMonitor)  {
			taskMonitor.setTitle(BuildProperties.APP_NAME);
			taskMonitor.setStatusMessage(message);
		}
	};
}
 

import org.cytoscape.work.Task; //导入依赖的package包/类
public static Task taskOf(Runnable runnable) {
	return new AbstractTask() {
		@Override
		public void run(TaskMonitor taskMonitor)  {
			runnable.run();
		}
	};
}
 

import org.cytoscape.work.Task; //导入依赖的package包/类
public static TaskFactory taskFactory(Provider<? extends Task> taskProvider) {
	return new AbstractTaskFactory() {
		@Override 
		public TaskIterator createTaskIterator() {
			return new TaskIterator(taskProvider.get());
		}
	};
}
 

import org.cytoscape.work.Task; //导入依赖的package包/类
@Override
public TaskIterator createTaskIterator() {
	final String tempColumn = UUID.randomUUID().toString();
	CyNetwork network = annotationSet.getParent().getNetwork();
	CyTable nodeTable = network.getDefaultNodeTable();
	
	// Create a temp column of cluster identifiers
	Task createTempColumnTask = TaskTools.taskOf(() -> {
		nodeTable.createColumn(tempColumn, Integer.class, false);
		int i = 0;
		for(Cluster cluster: annotationSet.getClusters()) {
			for(CyNode node : cluster.getNodes()) {
				network.getRow(node).set(tempColumn, i);
			}
			i++;
		}
	});
	
	// Layout the clusters
	Collection<Collection<CyNode>> clusters = annotationSet.getClusters().stream().map(Cluster::getNodes).collect(Collectors.toSet());
	LayoutClustersTaskFactory layoutTaskFactory = layoutTaskFactoryFactory.create(clusters, annotationSet.getParent().getNetworkView(), tempColumn);
	TaskIterator layoutTasks = layoutTaskFactory.createTaskIterator();
	
	// Delete the temp column
	Task deleteTempColumnTask = TaskTools.taskOf(() -> {
		nodeTable.deleteColumn(tempColumn);
	});
	
	
	TaskIterator tasks = new TaskIterator();
	tasks.append(TaskTools.taskMessage("Layout '" + annotationSet.getName() + "'"));
	tasks.append(createTempColumnTask);
	tasks.append(layoutTasks);
	tasks.append(deleteTempColumnTask);
	return tasks;
}
 

import org.cytoscape.work.Task; //导入依赖的package包/类
@Override
public void execute(TaskIterator iterator, TaskObserver observer) {
	TaskMonitor monitor = mock(TaskMonitor.class);
	FinishStatus finishStatus = null;
	
	Task task = null;
	try {
		while(iterator.hasNext()) {
			task = iterator.next();
			
			if(tasksToIgnore.contains(task.getClass())) {
				//System.out.println("Task Ignored: " + task.getClass());
				continue;
			}
			
			task.run(monitor);
			//System.out.println("Task Ran: " + task.getClass());
			
			if(task instanceof ObservableTask && observer != null) {
				observer.taskFinished((ObservableTask)task);
			}
		}
		
		finishStatus = FinishStatus.getSucceeded();
	} catch(Exception e) {
		finishStatus = FinishStatus.newFailed(task, e);
		e.printStackTrace();
		throw new AssertionError("Task failed", e);
	} finally {
		if(observer != null) {
			observer.allFinished(finishStatus);
		}
	}
}
 

import org.cytoscape.work.Task; //导入依赖的package包/类
public SimpleTaskFactory(FactoryMethod<Task> factory) {
    this.factory = factory;
}
 

import org.cytoscape.work.Task; //导入依赖的package包/类
private void registerCommand(BundleContext bc, String name, Class<? extends Task> type, String description) {
	TaskFactory taskFactory = taskFactory(injector.getProvider(type));
	registerCommand(bc, name, false, taskFactory, description);
}
 

import org.cytoscape.work.Task; //导入依赖的package包/类
Task createDrawTask(Cluster cluster);