Collections - Beginning Java 8 Language Features - page 558

catch (InterruptedException e) {
e.printStackTrace();
break;
}
}
}
}
Listing 12-22 has code for a consumer. It does the opposite of what a producer does. It removes elements from
the blocking queue. If the blocking queue is empty, it waits indefinitely for an element to become available. Both the
producer and consumer run in an infinite loop.
Listing 12-22. The Consumer Class for a Blocking Queue
// BQConsumer.java
package com.jdojo.collections;
import java.util.concurrent.BlockingQueue;
import java.util.Random;
public class BQConsumer extends Thread {
private final BlockingQueue<String> queue;
private final String name;
private final Random random = new Random();
public BQConsumer(BlockingQueue<String> queue, String name) {
this.queue = queue;
this.name = name;
}
@Override
public void run() {
while (true) {
try {
System.out.println(name +
" is trying to take an element. " +
"Remaining capacity: " +
queue.remainingCapacity());
String str = this.queue.take();
System.out.println(name + " took: " + str);
// Sleep between 1 and 5 seconds
int sleepTime = (random.nextInt(5) + 1) * 1000;
Thread.sleep(sleepTime);
}
catch (InterruptedException e) {
e.printStackTrace();
break;
}
}
}
}