Added ConcurrentBatchProcessor, demo program and unit tests.