public Dispatcher () throws InterruptedException {
		
		workers = new ArrayList<Worker>();
		
		for (int x=0;x<10;x++){
			JobImpl1 j = new JobImpl1();
			j.id="Job-"+x;
			qManager.push("Queue1",j);
		}
		
		for (int x=0;x<10;x++){
			Worker w1 = new Worker1(qManager,x);
				
			workers.add(w1);
			w1.start();
			
		}
		
		for (int x=0;x<10;x++){
			Worker w2 = new Worker2(qManager,x);
				
			workers.add(w2);
			w2.start();
			
			
		}
		
		
		
		//Thread.sleep(5000);
		/*for (int x=100;x<200;x++){
			JobImpl1 j = new JobImpl1();
			j.id="Job-"+x;
			qManager.push("Queue1",j);
		}*/
		
	
		Thread.sleep(2000);
		for (Worker ww:workers) {
			ww.interrupt();
			((Thread)ww).join();
		}
		
		System.out.println("Queue1: "+qManager.getCount("Queue1"));
		System.out.println("Queue2: "+qManager.getCount("Queue2"));
		
	}