FileDocCategorySizeDatePackage
JobScheduler.javaAPI DocExample7091Thu Feb 04 16:10:40 GMT 1999None

JobScheduler

public class JobScheduler extends Object implements Runnable

Fields Summary
public static final int
ONCE
public static final int
FOREVER
public static final long
HOURLY
public static final long
DAILY
public static final long
WEEKLY
public static final long
MONTHLY
public static final long
YEARLY
private ThreadPool
tp
private DaemonLock
dlock
private Vector
jobs
Constructors Summary
public JobScheduler(int poolSize)


	   
		tp = (poolSize > 0) ? new ThreadPool(poolSize) : null;
		Thread js = new Thread(this);
		js.setDaemon(true);
		js.start();
Methods Summary
private synchronized voidaddJob(JobScheduler$JobNode job)

		dlock.acquire();
		jobs.addElement(job);
		notify();
public voidcancel(java.lang.Runnable job)

		deleteJob(job);
public voidconfigureBackup(java.lang.Runnable job)

		Calendar now = Calendar.getInstance();
		System.out.println(now.getTime());

		executeAtNextDOW(job, now.getTime(), Calendar.SUNDAY);
private synchronized voiddeleteJob(java.lang.Runnable job)

		for (int i=0; i < jobs.size(); i++) {
			if (((JobNode) jobs.elementAt(i)).job == job) {
System.out.println("deleting job");
				jobs.removeElementAt(i);
				dlock.release();
				break;
			}
		}
public voidexecute(java.lang.Runnable job)

		executeIn(job, (long)0);
public voidexecuteAt(java.lang.Runnable job, java.util.Date when)

		executeAtAndRepeat(job, when, 1000, ONCE);
public voidexecuteAtAndRepeat(java.lang.Runnable job, java.util.Date when, long repeat)

		executeAtAndRepeat(job, when, repeat, FOREVER);
public voidexecuteAtAndRepeat(java.lang.Runnable job, java.util.Date when, long repeat, int count)

		JobNode jn = new JobNode();
		jn.job = job;
		jn.executeAt = when;
		jn.interval = repeat;
		jn.count = count;
		addJob(jn);
public voidexecuteAtNextDOW(java.lang.Runnable job, java.util.Date when, int DOW)

		Calendar target = Calendar.getInstance();
		target.setTime(when);
		while (target.get(Calendar.DAY_OF_WEEK) != DOW)
			target.add(Calendar.DATE, 1);
System.out.println(target.getTime());
		executeAt(job, target.getTime());
public voidexecuteIn(java.lang.Runnable job, long millis)

		executeInAndRepeat(job, millis, 1000, ONCE);
public voidexecuteInAndRepeat(java.lang.Runnable job, long millis, long repeat, int count)

		Date when = new Date(System.currentTimeMillis() + millis);
		executeAtAndRepeat(job, when, repeat, count);
public voidexecuteInAndRepeat(java.lang.Runnable job, long millis, long repeat)

		executeInAndRepeat(job, millis, repeat, FOREVER);
public static voidmain(java.lang.String[] args)

		Runnable r1 = new Runnable() {
			public void run() {
				System.out.print("1");
				try { Thread.sleep(5000); } catch (Exception ex) {};
				System.out.print("1");
			}
		};
		Runnable r2 = new Runnable() {
			public void run() {
				System.out.print("2");
				try { Thread.sleep(5000); } catch (Exception ex) {};
				System.out.print("2");
			}
		};
		Runnable r3 = new Runnable() {
			public void run() {
				System.out.print("3");
			}
		};
		Runnable r4 = new Runnable() {
			public void run() {
				System.out.print("4");
			}
		};

		JobScheduler js = new JobScheduler(0);
		Thread.sleep(1000);

		// Test 1 - General Test
		js.executeInAndRepeat(r1, 10000, 3000, 10); 
		js.executeInAndRepeat(r2, 20000, 1000, 10); 
		//Thread.sleep(11000);
		//js.cancel(r1);
		//js.cancel(r2);

		//js.configureBackup(r1);
		// Test 2 - Signature Test
		//Date in10Sec = new Date(System.currentTimeMillis()+10000L);
		//js.execute(r1);
		//js.executeIn(r2, 2000L);
		//js.executeInAndRepeat(r3, 10000L, 2000L);
		//js.executeInAndRepeat(r4, 10000L, 2000L, 5);
		//js.executeAt(r1, in10Sec);
		//js.executeAtAndRepeat(r2, in10Sec, 2000L);
		//js.executeAtAndRepeat(r3, in10Sec, 1000L, 5);
		//js.cancel(r4);
		//Thread.sleep(20000L);
		//js.cancel(r2);

		// Test 3 - Interval Test
		//js.executeInAndRepeat(r3, 10000L, JobScheduler.HOURLY);
		//js.executeInAndRepeat(r3, 10000L, JobScheduler.DAILY);
		//js.executeInAndRepeat(r3, 10000L, JobScheduler.WEEKLY);
		//js.executeInAndRepeat(r3, 10000L, JobScheduler.MONTHLY);
		//js.executeInAndRepeat(r3, 10000L, JobScheduler.YEARLY);
public synchronized voidrun()

		while (true) {
System.out.println("Checking Jobs...");
			long waitTime = runJobs();
			try {
System.out.println("Waiting for " + waitTime + " Milli-Seconds");
				wait(waitTime);
			} catch (Exception e) {};
		}
private synchronized longrunJobs()

		long minDiff = Long.MAX_VALUE;
		long now = System.currentTimeMillis();

		for (int i=0; i < jobs.size();) {
			JobNode jn = (JobNode) jobs.elementAt(i);
			if (jn.executeAt.getTime() <= now) {
System.out.println("Doing Job... " + i);
				if (tp != null) {
					tp.addRequest(jn.job);
				} else {
					Thread jt = new Thread(jn.job);
					jt.setDaemon(false);
					jt.start();
				}
				if (updateJobNode(jn) == null) {
System.out.println("Removing Job...");
					jobs.removeElementAt(i);
					dlock.release();
				}
			} else {
				long diff = jn.executeAt.getTime() - now;
				minDiff = Math.min(diff, minDiff);
				i++;
			}
		}
		return minDiff;
private JobScheduler$JobNodeupdateJobNode(JobScheduler$JobNode jn)

		Calendar cal = Calendar.getInstance();
		cal.setTime(jn.executeAt);
		if (jn.interval == MONTHLY) {
				// There is a minor bug. (see java.util.calendar)
				cal.add(Calendar.MONTH, 1);
				jn.executeAt = cal.getTime();
		} else if (jn.interval == YEARLY) {
				cal.add(Calendar.YEAR, 1);
				jn.executeAt = cal.getTime();
		} else {
				jn.executeAt = new Date(jn.executeAt.getTime() + jn.interval);
		}
		jn.count = (jn.count == FOREVER) ? FOREVER : jn.count - 1;
		return (jn.count != 0) ? jn : null;