Java 9 Concurrency Cookbook - Second Edition

How to do it...

Follow these steps to implement the example:

1. Create a class named MyPriorityTransferQueue that extends the PriorityBlockingQueue class and implements the TransferQueue interface:

        public class MyPriorityTransferQueue<E> extends                 PriorityBlockingQueue<E> implements TransferQueue<E> {

2. Declare a private AtomicInteger attribute named counter to store the number of consumers that are waiting to consume elements:

        private final AtomicInteger counter;

3. Declare a private LinkedBlockingQueue attribute named transferred:

        private final LinkedBlockingQueue<E> transfered;

4. Declare a private ReentrantLock attribute named lock:

        private final ReentrantLock lock;

5. Implement the constructor of the class to initialize its attributes: ...