Replaced ConcurrentQueue with BlockingCollection