How to do it...

Follow the steps described next to implement the example:

  1. Create a class named Client and specify that it implements the Runnable interface:
        public class Client implements Runnable{
  1. Declare a private LinkedBlockingDeque attribute parameterized by the String class named requestList:
        private final LinkedBlockingDeque<String> requestList;
  1. Implement the constructor of the class to initialize its attributes:
        public Client (LinkedBlockingDeque<String> requestList) {           this.requestList=requestList;         }
  1. Implement the run() method. Insert five String objects into the deque per second using the put() method of the requestList object. Repeat this cycle three times:
        @Override         public void run() {  for (int i=0; i<3; i++) ...

Get Java 9 Concurrency Cookbook - Second Edition now with the O’Reilly learning platform.

O’Reilly members experience books, live events, courses curated by job role, and more from O’Reilly and nearly 200 top publishers.