Please Help

Question about the task

The world is boring for boring people

Java Multithreading, Level 6, Lesson 10

Resolved

Cant Understand

Analyze BlockingQueue.
In the image and likeness of the Producer class, create a Consumer class that will output data from a BlockingQueue to the console.

Requirements:

The Consumer class must be in a separate file.
The Consumer class must implement the Runnable interface.
The Consumer class must contain a private BlockingQueue queue field.
The Consumer class must have a constructor with one parameter that initializes the queue field.
The Consumer class's run() method must constantly display the values from the queue.

package com.codegym.task.task26.task2610; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /* The world is boring for boring people */ public class Solution { public static void main(String[] args) throws Exception { BlockingQueue queue = new ArrayBlockingQueue(32); Producer producer = new Producer(queue); Consumer consumer = new Consumer(queue); ExecutorService executorService = Executors.newCachedThreadPool(); executorService.submit(producer); executorService.submit(consumer); Thread.sleep(2000); executorService.shutdownNow(); } }

Comments (3)

Popular
New
Old

You must be signed in to leave a comment

Wei Cui

Level 39 , Newark, United States

1 April 2020, 00:55

solution

public void run() {
        try {
            while (true) {
                System.out.println(queue.take());
                Thread.sleep(500);
            }
        } catch (InterruptedException e) {
            System.out.println(String.format("[%s] thread was terminated", Thread.currentThread().getName()));
        }
    }

Seb

Level 41 , Crefeld, Germany

26 January 2020, 00:16

useful

You can basically use the code from the Producer class as a blueprint (including the try and catch block, but without the variable i) - and then slightly adjust the while loop. The key code in the Producer class, which we need to adjust is the following excerpt: while (true) { queue.put(String.valueOf(i++)); Thread.sleep(300); } The main question now is - how can you possibly consume the content that the Producer class puts into the queue? You can also keep the same loop in the Consumer class - say: while (true) { // Get the content from the queue here... // Hint: The producer class used the method put ( queue.put() ) to put something into the queue. // Which method does the queue offer you to get something out of it? // And what is the return type of what you get out of the queue? // Once you've found the right method to poll the queue, you should be all set. ;-) :-) // Finally, print out the result to the console. }

null

Level 29 , Poznan, Poland

6 October 2019, 20:39

useful

That's not the way you print queue, also you don't need to set the value in producer.