I am trying to implement a Queue operation with producer-consumer functionality.
The producer reads data from a database in one thread and adds item to a queue which in turn is consumed by consumer down the line in a second thread.