ivana90
16-02-2010, 14:26
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
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