95 lines
2.6 KiB
Java
95 lines
2.6 KiB
Java
import java.lang.reflect.Method;
|
|
|
|
public class jobThread extends Thread {
|
|
private final int sleepResolution = 20; //Milliseconds
|
|
private long jobTime; //Milliseconds
|
|
private long elapsedTime;
|
|
private boolean isPaused, pauseStateChanged;
|
|
private long startTime;
|
|
private int jobID;
|
|
private boolean jobDone;
|
|
private Method parentAlgorithmDeallocate; //Our parent to notify when we're done.
|
|
private Object parentAlgorithm; //The actual instance of our parent class
|
|
|
|
/* Fields that we need to know when calling the deallocate */
|
|
private int jobSize;
|
|
private int beginningLocation;
|
|
|
|
public jobThread(long jobTime, int jobID, int jobSize, int beginningLocation, Method parentAlgorithmDeallocate, Object parentClass){
|
|
this.jobTime = jobTime;
|
|
this.parentAlgorithmDeallocate = parentAlgorithmDeallocate;
|
|
this.parentAlgorithm = parentClass;
|
|
this.elapsedTime = 0;
|
|
this.isPaused = false;
|
|
this.startTime = System.currentTimeMillis();
|
|
this.jobID = jobID;
|
|
this.jobSize = jobSize;
|
|
this.beginningLocation = beginningLocation;
|
|
|
|
this.jobDone = false;
|
|
}
|
|
|
|
public void setBeginning(int newBeginning){
|
|
this.beginningLocation = newBeginning;
|
|
}
|
|
|
|
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;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
Object[] deallocateArgs = {this.jobSize, this.beginningLocation};
|
|
//We're done, go ahead and notify our algorithm to clean us up
|
|
parentAlgorithmDeallocate.invoke(parentAlgorithm, deallocateArgs);
|
|
} catch (Exception e) {
|
|
return;
|
|
}
|
|
}
|
|
}
|