See BoundedQueue.java and UnboundedQueue.java.