/**@author Sherlock_yb
 * Created time:2014年9月26日
 */
package JTest;

import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.PriorityBlockingQueue;

import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import nlp.whu.utils.TaskConsumerSubjectFocus;
import nlp.whu.utils.TaskProducerSubjectFocus;
import nlp.whu.utils.TaskWrapperSubjectFocus;

/**@description：
 */
public class TaskRunnerTest {
	PriorityBlockingQueue<TaskWrapperSubjectFocus> taskQueue = new PriorityBlockingQueue<TaskWrapperSubjectFocus>(2, new TaskWrapperSubjectFocus.TaskPriorityComparator());
	Date startDate = new Date();
	Map<String, Integer> subjectMinuteGapMap = new HashMap<String, Integer>();
	TaskProducerSubjectFocus tp = new TaskProducerSubjectFocus(taskQueue, startDate, subjectMinuteGapMap);
	TaskConsumerSubjectFocus tc = new TaskConsumerSubjectFocus(taskQueue);
	Thread t2;
	@Before
	public void init(){
		subjectMinuteGapMap.put("1", 60);
		subjectMinuteGapMap.put("2", 30);
		subjectMinuteGapMap.put("3", 60);
		subjectMinuteGapMap.put("4", 30);
		t2 = new Thread(tp);
	}
	@After
	public void close(){
		System.out.println("test once done.");
		//do nothing
	}
	@Test
	public void TestRun(){
		t2.run();
	}
}