Hola estoy intentando implementar una cola, es decir tengo una serie de hilos que obtienen un id, y van a una cola la idea es que si la cola tiene 10 elementos no acepte ningún mas, y la tarea espere 2 segundos antes de volver a intentar introducir el id en la cola.
Para realizar esto tengo el siguiente código:
La clase principal donde creo 100 tareas que se van a introducir en la cola, y el QueueCleaner, que va a quitar un elemento de la cola cada 1 segundos
public class Main {
public static QueueOfTickets queueOfTickets = new QueueOfTickets();
public static void main(String[] args) {
Thread t2 = new Thread(new QueueCleaner());
t2.start();
for(int i = 0; i < 100; i++) {
Thread t1 = new Thread(new Task());
t1.start();
}
}
}
La cola de tickets
Esta es la condición que no se cumple, por que le indico que solo si la cola es menor de 10 agregue un elemento sin embargo llega a agregar 11 o 12 elementos mas
public class QueueOfTickets {
public static int id = 0;
private Queue<Integer> queue = new LinkedList<Integer>();
public QueueOfTickets() {}
public boolean addToQueue(Integer integer) {
if(queue.size() < 10) {
queue.add(integer);
System.out.println("Int " + integer + " add to queue, size: " + queue.size());
return true;
}else {
return false;
}
}
public void poll() {
System.out.println("Deque: " + queue.poll());
}
}
Task Esta es la clase que va a agregar elementos a la cola
public class Task implements Runnable {
int id = 0;
public void run(){
QueueOfTickets.id++;
id = QueueOfTickets.id;
while(!Main.queueOfTickets.addToQueue(id)) {
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
Y esta es la tarea que quita cada segundo un elemento de la cola
public class QueueCleaner implements Runnable {
public void run(){
while(true) {
Main.queueOfTickets.poll();
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
Cuando ejecuto esto ni de lejos llego a poder insertar 100 elementos llegado un punto solo retorna null, ademas de que introduce mas de un elementos sobre el total de los permitidos en la condición
Alguna idea?
Gracias.