Productor/Consumidor

[Stoyicker]

Buenas, necesito implementar el problema concurrente de Productor/Consumidor mediante synchronized, wait() y notify().

Debe haber:

Una clase productor.
Una clase consumidor.
Una claseQ, especificada más abajo, y que puede ser modificada de ser necesario (añadiendo syncrhonized, wait() o notify() de hacer falta).
Una clase Main que crea tres objetos, una claseQ, un productor y un consumidor.

claseQ:

public class claseQ {

int id = 0;

public int get() throws InterruptedException {
return id;
}

public void put(int e) {
id = e;
}
}

Acción de producir:

obj.put(i);
System.out.println("Objeto introducido: "+i);

Acción de consumir:

System.out.println("Objeto obtenido: " + obj.get());

Lo he intenado millones de veces pero las pocas que no me sale IlegalMonitorStatException no se sincronizan; el productor va tremendamente más rápido que el consumidor. ¿Puede alguien escribir las clases main, productor y consumidor (y claseQ, si hiciese falta editarla), para ver si con la solución lo veo más claro?

[Heimish2000]

¿Puedes publicar lo que ya tienes y así trabajamos sobre esa base?

[Stoyicker]

Hombre, si crees que va a ser útil...

Main:

Código C:

public class Main extends Thread {
 
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        claseQ cola = new claseQ();
        Productor producer = new Productor(cola);
        Consumidor consumer = new Consumidor(cola, producer);
        producer.start();
        consumer.start();
    }
}
 

claseQ:

Código C:

public class claseQ {
 
    int id = 0;
 
    public int get() throws InterruptedException {
        return id;
    }
 
    public void put(int e) {
        id = e;
    }
 

Productor:

Código C:

public class Productor extends Thread implements Runnable {
 
    claseQ obj;
 
    public Productor(claseQ obja) {
        obj=obja;
    }
 
    public void run(){
    for (int i = 0; 1 < 2; i++) {
            obj.put(i);
            System.out.println("Objeto introducido: "+i);
        }
    }
}
 

Consumidor:

Código C:

public class Consumidor extends Thread implements Runnable {
 
    claseQ obj;
 
    public Consumidor(claseQ obja, Productor p) {
        obj = obja;
    }
 
    public void run() {
            for (int i = 0; 1 < 2; i++) {
                System.out.println("Objeto obtenido: " + obj.get());
        }
    }
}
 

He quitado todas las movidas de waits, synchronizeds y notifys que había puesto porque ya las había probado y provocan siempre interbloqueo o excepción T.T

[Heimish2000]

¿Por qué le pasas el productor al constructor del consumidor y luego no lo utilizas?

Veo que en el main invocas a una función start, pero en las clases no existe ese método, existe un método run.

Luego, en la forma que lo tienes el consumidor no consume todos los objetos de la cola, simplemente coge el último que haya insertado el productor

[posman]

Iniciado por Heimish2000

Veo que en el main invocas a una función start, pero en las clases no existe ese método, existe un método run.

El metodo start() es de la clase Thread

Stoyicker, en las clases que vas a utilizar para crear hilos no es necesario que heredes de Thread y Runnable. Se utiliza una u otra.

Aunque es un ejercicio que deberias hacer tu, tutoriales sobre este tipo de tareas existen muchas en internet. Lee algunas para que te des una idea, NO LAS COPIES!

http://download.oracle.com/javase/tu...guardmeth.html
http://www.java2s.com/Tutorial/Java/...erandQueue.htm