Implement thread-safe blocking queue