Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /* ************************************************************************
  #
  #  DivConq
  #
  #  http://divconq.com/
  #
  #  Copyright:
  #    Copyright 2014 eTimeline, LLC. All rights reserved.
  #
 #  License:
 #    See the license.txt file in the project's top-level directory for details.
 #
 #  Authors:
 #    * Andy White
 #
 ************************************************************************ */
 package divconq.work;
 
 import java.util.List;
 import java.util.Map;
 
 
 public class TaskCountDownCallback extends CountDownCallback {
 	protected int delayComplete = 2;
 	protected List<Tasktasks = new ArrayList<>();
 	protected HashMap<StringTaskRunruns = new HashMap<>();
 	
 		public void completed(OperationContext or) {
 		}				
 	};
 	
 	public void setDelayComplete(int v) {
 		this. = v;
 	}
 	
 		return this.;
 	}
 	
 	public TaskCountDownCallback() {
 		super(0, null);
 	}
 	
 	public TaskCountDownCallback(int tasksOperationCallback callback) {
 		super(taskscallback);
 	}
 	
 	public void setCallback(OperationCallback v) {
 		this. = v;
 	}
 	
 	public List<TaskgetTasks() {
 		return this.;
 	}
 	
 	public Map<StringTaskRungetRuns() {
 		return this.;
 	}
 	
 	public TaskRun getRun(String id) {
 		return this..get(id);
 	}
 
 	public int countDown() {
 		this..lock();
 		
 		try {
 			int res = this..decrementAndGet();
 			
 			if (res < 0)
 				res = 0;
 			
 			// make this a delayed action
 			if (res == 0) {
 				// be sure we are running as the task that requested this callback
 				OperationContext.set(this..getContext());
 				
 				Task reporttask = new Task()
 						public void run(TaskRun run) {
 						}
 					});
 				
 				..getScheduler().runIn(reporttaskthis.);		
			}
			return res;
		}
		finally {
			this..unlock();
		}
	}
	public void add(Task task) {
		this.increment();
		this..add(task);
	}
	public void submit() {
		for (Task t : this.) {
			this..put(t.getId(), run);
		}
	}
New to GrepCode? Check out our FAQ X