This is just a code the instructor said we will use. Just watch the video I guess package consumer; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; public...

Implement the producer-consumer architecture we covered in class on 4/1/2021. It's in the video.
Video --> (https://web.microsoftstream.com/video/825edebc-21d9-441f-90a8-c450893f5047)


This is just a code the instructor said we will use. Just watch the video I guess package consumer; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; public class ConsumerThread extends Thread { private BlockingQueue myBQ; private String queueID; private int counter; public ConsumerThread(BlockingQueue bq, String queueID) { myBQ = bq; this.queueID = queueID; counter = 0; } public void run() { while (true) { String buffer = null; try { buffer = myBQ.take(); // blocks here if necessary counter++; System.out.println("Queue " + queueID + " took " + buffer + ", " + counter + " items taken."); } catch (Exception ex) {} } } }