Generation of consumers checks for the number of cores and adds based on that.
One core per consumer.
ConsumerProducerTest.run() now checks for the number of cores.
One consumer is generated per core.