import com.foolish.collections.ConcurrentQueue;
public class ConcurrentApp {
public static void main(String[] args) {
ConcurrentQueue<String> queue = new ConcurrentQueue<>();
// Add elements
queue.add("Element 1");
queue.add("Element 2");
queue.add("Element 3");
// Retrieve and remove elements
System.out.println(queue.poll()); // Output: Element 1
System.out.println(queue.poll()); // Output: Element 2
System.out.println(queue.poll()); // Output: Element 3
// Concurrent access
new Thread(() -> {
queue.add("Element 4");
}).start();
new Thread(() -> {
System.out.println(queue.poll()); // Output: Element 4
}).start();
}
}
<dependencies>
<dependency>
<groupId>com.foolish</groupId>
<artifactId>foolish-collections</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies>
