Interfaz Java BlockingQueue

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

La BlockingQueueinterfaz del Collectionsmarco de Java amplía la Queueinterfaz. Permite que cualquier operación espere hasta que se pueda realizar 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 a eliminar.

Clases que implementan BlockingQueue

Dado que 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 utilizar las colas de bloqueo?

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

 // Array implementation of BlockingQueue BlockingQueue animal1 = new ArraryBlockingQueue(); // LinkedList implementation of BlockingQueue BlockingQueue animal2 = new LinkedBlockingQueue(); 

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

Métodos de BlockingQueue

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 utilizar con tiempos de espera. Es decir, podemos pasar las 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 regresa 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 que se eliminarán.

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 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 subproceso está insertando elementos en la cola y otro subproceso está eliminando elementos de la cola.

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