A generic library to process data with  multiple thread. A Producer Consumer implemention over BlockingQueue.