Added thread-based AsyncConsumer and AsyncBufferedConsumer (#74)