From a1be9111fa40fa009029d5660587a66f6a0a2151 Mon Sep 17 00:00:00 2001
From: Bradlee Speice <bspeice@BSPEICE-XUBUNTU.(none)>
Date: Fri, 28 Sep 2012 18:07:28 -0400
Subject: [PATCH] Add code for the Job itself

---
 Job.java       | 59 +++++++++++++++++++++++--------------
 jobThread.java | 80 ++++++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 117 insertions(+), 22 deletions(-)
 create mode 100644 jobThread.java

diff --git a/Job.java b/Job.java
index ac9cff0..966e9dd 100644
--- a/Job.java
+++ b/Job.java
@@ -1,22 +1,37 @@
-/*Job Class
- * Contains Int Size and Int Time
- */
-
-public class Job {
-	private int size,time;
-	
-	public Job(int s, int t){
-		size = s;
-		time = t;
-	}
-	
-	public void setSize(int s){size = s;}
-	public void setTime(int t){time = t;}
-	
-	public int getSize(){return size;}
-	public int getTime(){return time;}
-	
-	public String toString(){
-		return "("+size+","+time+")";
-	}
-}
+/*
+ * Author: Bradlee Speice
+ * Job Class
+ * 
+ * The purpose of this class is to simulate a running "Job" in memory. To create a new Job, call the
+ * "start" method, and inform the job of how long it should run, and give it an identifier.
+ * The job will use this to report back that it is done. If you need to pause the job, you
+ * can do so. Finally, the job will report back to whoever called it that it needs to be destroyed.
+ * If there are any questions, email bspeice@uncc.edu
+ */
+public class Job {
+	private jobThread myThread; //Reference to the thread we control
+	private boolean myThreadPaused; //Used to keep track of the execution state of our thread
+	//private BaseAlgorithm parentAlgorithm; //Used for knowing who to tell that we're done.
+	
+	public	Job(int jobTime, int jobID/*, BaseAlgorithm parentAlgorithm */){
+		//Create a new job, and start it running
+		myThread = new jobThread(jobTime, jobID /*, parentAlgorithm*/);
+		myThread.start();
+	}
+	
+	public void pause(){
+		if (!myThreadPaused){
+			myThread.pause();
+			myThreadPaused = true;
+		}
+	}
+	
+	public void resume(){
+		if (myThreadPaused){
+			myThread.jobResume();
+			myThreadPaused = false;
+		}
+	}
+	
+	
+}
diff --git a/jobThread.java b/jobThread.java
new file mode 100644
index 0000000..a04edc2
--- /dev/null
+++ b/jobThread.java
@@ -0,0 +1,80 @@
+public class jobThread extends Thread {
+	private final int sleepResolution = 200; //Milliseconds
+	private long jobTime; //Milliseconds
+	private long elapsedTime;
+	private boolean isPaused, pauseStateChanged;
+	private long startTime;
+	private int jobID;
+	private boolean jobDone;
+	/* private BaseAlgorithm parentAlgorithm *///Our parent to notify when we're done.
+	
+	public jobThread(long jobTime, int jobID /*, BaseAlgorithm parentAlgorithm*/){
+		this.jobTime = jobTime;
+		elapsedTime = 0;
+		isPaused = false;
+		startTime = 0;
+		this.jobID = jobID;
+		//this.parentAlgorithm = parentAlgorithm;
+	}
+	
+	public void pause(){
+		synchronized(this){
+			isPaused = true;
+			pauseStateChanged = true;
+		}
+	}
+	
+	public void jobResume(){
+		synchronized(this){
+			isPaused = false;
+			pauseStateChanged = true;
+		}
+	}
+	
+	public void run(){
+		//The event loop.
+		//Basically, check that elapsedTime plus current time delta
+		//are not greater than the time we're supposed to run.
+		//If paused, don't do anything until we resume
+		try{
+			while (!jobDone){
+				//Begin event logic
+				sleep(sleepResolution);
+				
+				synchronized(this){
+					if (pauseStateChanged){
+						if (isPaused){
+							//We have just been paused, save the time that we've currently
+							//been running, and then go back to the event loop
+							elapsedTime += System.currentTimeMillis() - startTime;
+							continue;
+						} else {
+							//We have just been resumed, restart the timer
+							startTime = System.currentTimeMillis();
+							continue;
+						}
+					} else {
+						if (isPaused){
+							//Nothing much happening, we're still paused.
+							continue;
+						} else {
+							//Not paused, Check if we need to keep running
+							long currentDelta = System.currentTimeMillis() - startTime;
+							if (currentDelta + elapsedTime >= jobTime){
+								jobDone = true;
+							}
+						}
+					}
+				}
+			}
+			
+			//We're done, go ahead and notify our algorithm to clean us up
+			/* parentAlgorithm.deallocate(jobID); */
+		} catch (Exception e) {
+			return;
+		}
+		
+		
+				
+	}
+}