using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Diagnostics;

namespace JobTest {
	class JobQueue {
		private Job defaultJob = null;
		private bool keepGoing = false;
		private int runNum = 0;
		private Queue<Job> pendingJobs = new Queue<Job>();

		public delegate int Job(); // return value is wait time

		public JobQueue(Job defaultJob) {
			this.defaultJob = defaultJob;
		}

		public void AddJob(Job job) { pendingJobs.Enqueue(job); }

		public void Run() {
			keepGoing = true;
			while (keepGoing) {
				Debug.WriteLine("Job " + ++runNum);
				Job job = (pendingJobs.Count > 0) ? pendingJobs.Dequeue() : this.defaultJob;
				int sleepTime = job();
				if (keepGoing && sleepTime > 0) {
					System.Threading.Thread.Sleep(sleepTime);
				}
			}
		}

		public void Stop() {
			keepGoing = false;
		}

	}

	class Program {
		static int Ajob() {
			Debug.WriteLine("AJob");
			return 1000;
		}

		static void Main(string[] args) {
			JobQueue jc = new JobQueue(delegate() { Debug.WriteLine("Default Job"); return 2000; });
			new Thread(new ThreadStart(jc.Run)).Start();
			System.Threading.Thread.Sleep(2000);
			jc.AddJob(Ajob);
			jc.AddJob(Ajob);
			jc.AddJob(new JobQueue.Job(delegate() { Debug.WriteLine("Another Job"); return 0; }));
			jc.AddJob(Ajob);
			System.Threading.Thread.Sleep(1000);
			jc.AddJob(Ajob);
			System.Threading.Thread.Sleep(10000);
			jc.Stop();


		}
	}
}