How to write a Concurrent Thread-safe Queue from scratch?