Shulou(Shulou.com)06/03 Report--

This article introduces the "Java blocking queue implementation and application method tutorial" related knowledge, in the actual case operation process, many people will encounter such a dilemma, then let the editor lead you to learn how to deal with these situations! I hope you can read it carefully and be able to achieve something!

1. Handwritten producer-consumer model

The so-called producer-consumer model can be compared with examples in our lives: I went to a stall to buy food, and the boss put all the prepared snacks on a plate for me to choose from. In that case, the boss is the producer; I am the consumer; and the disk is the blocking queue, which is used as a buffer for production and consumption. Therefore, the blocking queue plays an important role in the producer and consumer model.

This time, I'll show you how to handwrite the blocking queue (you can also use the blocking queue that comes with the Java library).

Handwritten blocking queues perform only the two most basic functions: queuing and demarcation. The reason why it is called blocking queue is that when the team is empty or full, the blocking will be realized, and the blocking will not be removed until the queue is not empty or dissatisfied.

The implementation of the handwritten blocking queue is as follows:

/ / blocking queue BlockQueuestatic class BlockQueue {/ / this queue is implemented in an array. We make the maximum capacity of this queue 10 private int [] items = new int [10]; private int head = 0; private int tail = 0; private int size = 0; private Object locker = new Object () / / join public void put (int item) throws InterruptedException {synchronized (locker) {while (size = = items.length) {/ / when joining the team, block locker.wait () if the team is full;} items [tail++] = item / / if the end is reached, return to if (tail > = items.length) {tail = 0;} size++; locker.notify () }} / / public int back () throws InterruptedException {int ret = 0; synchronized (locker) {while (size = = 0) {/ / when leaving the queue, block locker.wait () if the queue is empty } ret = items [head++]; if (head > = items.length) {head = 0;} size--; locker.notify ();} return ret;}}

Use two threads to act as producers and consumers:

Public static void main (String [] args) throws InterruptedException {BlockQueue blockQueue = new BlockQueue (); / / producer thread Thread produce = new Thread () {@ Override public void run () {for (int I = 0 for)

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.