Пример очереди блокировки Java
Сегодня мы рассмотрим Java BlockingQueue. java.util.concurrent.BlockingQueue
– это очередь java, которая поддерживает операции, ожидающие, пока очередь не станет непустой при извлечении и удалении элемента, и ожидание освобождения места в очереди при добавлении элемент.
Очередь блокировки Java
put(E e)
: этот метод используется для вставки элементов в очередь. Если очередь заполнена, она ожидает освобождения места.E take()
: этот метод извлекает и удаляет элемент из начала очереди. Если очередь пуста, она ожидает, пока элемент станет доступным.
Теперь давайте реализуем задачу производителя-потребителя, используя java BlockingQueue.
Пример Java BlockingQueue — сообщение
Просто обычный объект Java, который будет создан Producer и добавлен в очередь. Вы также можете назвать его полезной нагрузкой или сообщением очереди.
package com.journaldev.concurrency;
public class Message {
private String msg;
public Message(String str){
this.msg=str;
}
public String getMsg() {
return msg;
}
}
Пример Java BlockingQueue — Производитель
Класс производителя, который будет создавать сообщения и помещать их в очередь.
package com.journaldev.concurrency;
import java.util.concurrent.BlockingQueue;
public class Producer implements Runnable {
private BlockingQueue<Message> queue;
public Producer(BlockingQueue<Message> q){
this.queue=q;
}
@Override
public void run() {
//produce messages
for(int i=0; i<100; i++){
Message msg = new Message(""+i);
try {
Thread.sleep(i);
queue.put(msg);
System.out.println("Produced "+msg.getMsg());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//adding exit message
Message msg = new Message("exit");
try {
queue.put(msg);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
Пример Java BlockingQueue — потребитель
Класс-потребитель, который будет обрабатывать сообщения из очереди и завершаться при получении выходного сообщения.
package com.journaldev.concurrency;
import java.util.concurrent.BlockingQueue;
public class Consumer implements Runnable{
private BlockingQueue<Message> queue;
public Consumer(BlockingQueue<Message> q){
this.queue=q;
}
@Override
public void run() {
try{
Message msg;
//consuming messages until exit message is received
while((msg = queue.take()).getMsg() !="exit"){
Thread.sleep(10);
System.out.println("Consumed "+msg.getMsg());
}
}catch(InterruptedException e) {
e.printStackTrace();
}
}
}
Пример Java BlockingQueue — служба
Наконец, нам нужно создать службу BlockingQueue для производителя и потребителя. Эта служба производителя-потребителя создаст BlockingQueue с фиксированным размером и предоставит общий доступ как производителям, так и потребителям. Эта служба запустит потоки производителя и потребителя и завершит работу.
package com.journaldev.concurrency;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class ProducerConsumerService {
public static void main(String[] args) {
//Creating BlockingQueue of size 10
BlockingQueue<Message> queue = new ArrayBlockingQueue<>(10);
Producer producer = new Producer(queue);
Consumer consumer = new Consumer(queue);
//starting producer to produce messages in queue
new Thread(producer).start();
//starting consumer to consume messages from queue
new Thread(consumer).start();
System.out.println("Producer and Consumer has been started");
}
}
Вывод приведенной выше примерной программы java BlockingQueue показан ниже.
Producer and Consumer has been started
Produced 0
Produced 1
Produced 2
Produced 3
Produced 4
Consumed 0
Produced 5
Consumed 1
Produced 6
Produced 7
Consumed 2
Produced 8
...
Сон Java Thread используется производителем и потребителем для создания и потребления сообщений с некоторой задержкой.