[Java] Problema coda

[ivana90]

Salve ragazzi dato questo testo:
Definire la classe Casella che contiene una coda di oggetti Msg e definisce due metodi void invia(Msg a) e Msg ricevi() per inserire e togliere un oggetto Msg dalla coda.
Il metodo ricevi() deve attendere che ci sia almeno un messaggio in coda.
Definire inoltre una classe MioThread che estende Thread
con costruttore con argomenti int id,int quanti,Casella c.
I MioThread devono ricevere messaggi tramite c.Ogni qualvolta che c restituisce un messaggio NON indirizzato a loro devono reinserirlo in c.Dopo aver ricevuto quanti messaggi a loro indirizzati devono stampare "thread id:ricevuto :somma" e terminare,somma è la somma dei valori dei messaggi a loro indirizzati.I thread sono avviati dal loro costruttore.
Questa è la mia soluzione:

class Casella

{

	private Msg  [] vect;

	private int presenti ;

	private int max;

	private int front;

	private int back;

	

	

	Casella()

	{

		vect=new Msg [16];

		this.max=16;

		presenti=0;
		

	}

	public synchronized void invia(Msg m)	

	{	if (presenti<max){

		vect[back]=m;

		presenti ++;

		back=(back+1)%max;		

		notifyAll();}

	}

	

	public synchronized Msg ricevi() throws InterruptedException

	{

		while (presenti<=0) wait();

		Msg a=vect[front];		

		presenti --;

		front=(front+1)%max;

		return a;

	}

}

	



class MioThread extends Thread

{

	private int id;

	private int quanti;

	private Casella c;
	

	

	MioThread(int id,int quanti,Casella c)

	{

		this.id=id;

		this.quanti=quanti;

		this.c=c;

		start();

	}



	public  void run()

	{	int somma=0;
			try

		{ 

		       

			while(quanti!=0)

			{

			Msg b=c.ricevi();

			if (b.dest==id){quanti --; somma+=b.msg;}

				else c.invia(b);

			}

		

			

		   

			

		System.out.println("Thread " +id+":ricevuto "+somma);}catch(InterruptedException e)			{}

		

	

	}

}

E questo è il main che non può cambiare:

class Msg {

	public int dest;

	public int msg;

	public Msg(int dest, int msg) {

		this.dest = dest;

		this.msg = msg;

	}

}



class Thread2 extends Thread {

	int[] v;

	int dest;

	Casella c;



	Thread2(int[] v, int dest, Casella c) {

		this.v = v.clone();

		this.dest = dest;

		this.c = c;

		start();

	}



	public void run() {

		Msg m = new Msg(dest, 0);

		for (int i: v) {

			m.msg = i;

			c.invia(m);

			try {

				sleep(10);

			} catch (InterruptedException e) {

			}

		}

	}

}



class Pesa {

	public static void main(String[] args) {

		int[] d = { 2, 0, 1 };

		int[][] v = {

			{ 1, 2, 3 },

			{ 4, 5, 6 },

			{ 7, 8, 9 } };



		Casella c = new Casella();

		for (int i = 0; i < 3; i++) {

			new MioThread(i, 3, c);

			new Thread2(v[i], d[i], c);

		}

	}

}

I risultati ogni tanto non vanno bene.
Sapete dirmi perchè?
Un bacio a tutto il forum

[PGI-Bis]

C'è un bel data race su Msg nella classe Thread2.

Msg m = new Msg(dest, 0);
for(int i : v) {
    m.msg = i;
    c.invia(m);
    eccetera

In pratica ciò che capita è che Thread2 immette nella coda più messaggi con lo stesso valore.

Crea il messaggio A con valore 1 e lo infila nella coda
Crea il messaggio B con valore 2 e lo infila nella coda
Crea il messaggio C con valore 3 e lo infila nella coda

Siccome A, B e C sono lo stesso messaggio (Thread2 inizializza un unico Msg fuori dal ciclo e poi cambia il suo campo msg per i tre invii) è possibile che alcuni o tutti tra i messaggi precedenti abbiano, al momento della lettura, lo stesso valore di un messaggio successivo. Vale a dire che sono veri, per il Thread 2 che "opera" sui valori (1, 2, 3), i casi:

(1, 2, 3) = 6
(2, 2, 3) = 7
(2, 3, 3) = 8
(3, 3, 3) = 9

Soluzioni.

Devi evitare il pastrocchio che fa Thread2, cioè il fatto che questo Thread intervenga sempre sullo stesso valore.

Per rendere breve una storia molto lunga, siccome nella tua Casella ricevi è mutualmente esclusivo previeni il problema "clonando" il messaggio ricevuto (dalla coda) prima di immetterlo nel vettore.

Ora hai:

vect[back] = m;

se diventa:

vect[back] = new Msg(m.dest, m.msg);

tutto si sistema.

[ivana90]

Grazie compà.. ma non posso usare:
Msg a=vect[front].clone(); il compilatore mi dà errore..

[PGI-Bis]

Originariamente inviato da PGI-Bis

Ora hai:

vect[back] = m;

se diventa:

vect[back] = new Msg(m.dest, m.msg);

tutto si sistema.

Metodo invia(Msg) di Casella.