import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
public class ProducerConsumerExample {
private final Queue<Integer> queue = new ConcurrentLinkedQueue<>();
public void produce(int value) {
queue.add(value);
}
public int consume() {
if (!queue.isEmpty()) {
return queue.poll();
}
return -1;
}
}
