public synchronized void addReduceTask(ArrayDeque<ReduceTask> task) {
		for (ReduceTask t : task) {
			ReduceWorker worker = new ReduceWorker(t, this, dfs);
			Thread thread = new Thread(worker);
			thread.start();
			reduceTasks.addLast(t);
		}
	}