Java BlockingQueue

En este tutorial, aprenderemos sobre la interfaz Java BlockingQueue y sus métodos.

Reúna a su equipo con Slack, el centro de colaboración para el trabajo.ANUNCIOS A TRAVÉS DE CARBONO

La BlockingQueueinterfaz del Collectionsmarco de Java extiende la Queueinterfaz. Permite que cualquier operación espere hasta que pueda realizarse con éxito.

Por ejemplo, si queremos eliminar un elemento de una cola vacía, entonces la cola de bloqueo permite que la operación de eliminación espere hasta que la cola contenga algunos elementos para ser eliminados.

---

Clases que implementan BlockingQueue

Como BlockingQueuees una interfaz, no podemos proporcionar la implementación directa de la misma.

Para usar la funcionalidad de BlockingQueue, necesitamos usar clases que lo implementen.

• ArrayBlockingQueue
• LinkedBlockingQueue

---

¿Cómo usar las colas de bloqueo?

Debemos importar el java.util.concurrent.BlockingQueuepaquete para poder usarlo BlockingQueue.

// Array implementation of BlockingQueue
BlockingQueue<String> animal1 = new ArraryBlockingQueue<>();

// LinkedList implementation of BlockingQueue
BlockingQueue<String> animal2 = new LinkedBlockingQueue<>();

Aquí, hemos creado objetos animal1 y animal2 de clases ArrayBlockingQueuey LinkedBlockingQueue, respectivamente. Estos objetos pueden usar las funcionalidades de la BlockingQueueinterfaz.

---

Métodos de bloqueo

Según si una cola está llena o vacía, los métodos de una cola de bloqueo se pueden dividir en 3 categorías:

Métodos que arrojan una excepción

• add()- Inserta un elemento en la cola de bloqueo al final de la cola. Lanza una excepción si la cola está llena.
• element()- Devuelve el encabezado de la cola de bloqueo. Lanza una excepción si la cola está vacía.
• remove()- Elimina un elemento de la cola de bloqueo. Lanza una excepción si la cola está vacía.

---

Métodos que devuelven algún valor.

• offer()- Inserta el elemento especificado en la cola de bloqueo al final de la cola. Devuelve falsesi la cola está llena.
• peek()- Devuelve el encabezado de la cola de bloqueo. Devuelve nullsi la cola está vacía.
• poll()- Elimina un elemento de la cola de bloqueo. Devuelve nullsi la cola está vacía.

Más en oferta () y encuesta ()

El método offer()y poll()se puede usar con tiempos de espera. Es decir, podemos pasar unidades de tiempo como parámetro. Por ejemplo,

offer(value, 100, milliseconds)

Aquí,

• valor es el elemento que se insertará en la cola
• Y hemos establecido un tiempo de espera de 100 milisegundos

Esto significa que el offer()método intentará insertar un elemento en la cola de bloqueo durante 100milisegundos. Si el elemento no se puede insertar en 100 milisegundos, el método vuelve false.

Nota: En lugar de milliseconds, también podemos utilizar estas unidades de tiempo: days, hours, minutes, seconds, microsecondsy nanosecondsen offer()y poll()métodos.

---

Métodos que bloquean la operación.

El BlockingQueuetambién proporciona métodos para bloquear las operaciones y esperar si la cola está llena o vacía.

• put()- Inserta un elemento en la cola de bloqueo. Si la cola está llena, esperará hasta que la cola tenga espacio para insertar un elemento.
• take()- Elimina y devuelve un elemento de la cola de bloqueo. Si la cola está vacía, esperará hasta que la cola tenga elementos para eliminar.

Supongamos que queremos insertar elementos en una cola. Si la cola está llena, el put()método esperará hasta que la cola tenga espacio para insertar elementos.

Del mismo modo, si queremos eliminar elementos de una cola. Si la cola está vacía, el take()método esperará hasta que la cola contenga elementos para eliminar.

---

Implementación de BlockingQueue en ArrayBlockingQueue

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ArrayBlockingQueue;

class Main {

    public static void main(String[] args) {
      // Create a blocking queue using the ArrayBlockingQueue
      BlockingQueue<Integer> numbers = new ArrayBlockingQueue<>(5);

      try {
        // Insert element to blocking queue
        numbers.put(2);
        numbers.put(1);
        numbers.put(3);
        System.out.println("BLockingQueue: " + numbers);

        // Remove Elements from blocking queue
        int removedNumber = numbers.take();
        System.out.println("Removed Number: " + removedNumber);
      }

      catch(Exception e) {
          e.getStackTrace();
      }
    }
}

Salida

BlockingQueue: [2, 1, 3]
Elemento eliminado: 2

Para obtener más información ArrayBlockingQueue, visite Java ArrayBlockingQueue .

---

¿Por qué BlockingQueue?

En Java, BlockingQueuese considera la colección segura para subprocesos . Es porque puede ser útil en operaciones de subprocesos múltiples.

Supongamos que un hilo está insertando elementos en la cola y otro hilo está eliminando elementos de la cola.

Ahora, si el primer subproceso se ejecuta más lentamente, la cola de bloqueo puede hacer que el segundo subproceso espere hasta que el primer subproceso complete su operación.

• JAVA ARRAYDEQUE ANTERIOR