`ArrayBlockingQueue` is one implementation of the `java.util.concurrent.BlockingQueue` which internally store the queue elements inside an array. The `ArrayBlockingQueue` can store elements for the size defined when the object is initialized, by the constructor. Once it size is defined it cannot be change or resize.

The code snippet below demonstrate the `ArrayBlockingQueue` class. We initialize the queue to allow its internal array to store maximum of 64 elements.

“`java
package org.kodejava.util.concurrent;

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

public class ArrayBlockingQueueExample {
private final BlockingQueue<String> sharedQueue = new ArrayBlockingQueue<>(64);

public static void main(String[] args) {
new ArrayBlockingQueueExample().createProducerConsumer();
}

private void createProducerConsumer() {
new Thread(() -> {
while (true) {
System.out.println(Thread.currentThread().getName());
try {
sharedQueue.put("DATA-" + UUID.randomUUID());
Thread.sleep(250);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "Producer Thread").start();

new Thread(() -> {
while (true) {
System.out.print(Thread.currentThread().getName() + " => ");
try {
System.out.println(sharedQueue.take());
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "Consumer Thread-1").start();
}
}
“`