Mrta: Created page with "Esercizio 1: Scrivere un monitor che implementi un buffer limitato (SIZE elementi) dove i messaggi abbiano associata una priorita'. I processi produttori richiamano pbb.enqueu..."

2014-05-19T14:58:06Z

Created page with "Esercizio 1: Scrivere un monitor che implementi un buffer limitato (SIZE elementi) dove i messaggi abbiano associata una priorita'. I processi produttori richiamano pbb.enqueu..."

New page

Esercizio 1: Scrivere un monitor che implementi un buffer limitato (SIZE elementi) dove
i messaggi abbiano associata una priorita'. I processi produttori richiamano
pbb.enqueue(m,prio)
mentre i processi consumatori chiamano
m=pbb.dequeue()
I primi SIZE processi produttori pongono i loro elementi nel buffer senza bloccarsi, i successivi si fermano in attesa.
Il consumatore deve sempre prendere l'elemento a priorita' massima fra quelli nel buffer *e* fra quelli in attesa.

<syntaxhighlight lang="C">
struct el {
int prio;
condition c;
};

struct bufel {
T payload;
struct el prioc;
};

struct bufel buf[SIZE+1];
int nbuf, nqueue;
condition oktoread;

procedure entry void enqueue(T m, int prio) {
if(nbuf>=SIZE) {
el=new(struct el); el.prio=prio;
nqueue++; q.enqueue(el); nqueue--;
free(el);
}
buf[nbuf].prio=prio; buf[nbuf].payload=m;
nbuf++;
sort(buf, nbuf); //in ordine crescente
oktoread.signal();
}

procedure entry dequeu(void) {
if(nbuf+nqueue==0)
oktoread.wait()
if(nqueue>0) {
el=q.dequeue(); //quello a prio max
el.c.signal();
}
nbuf--;
return nuf[nbuf].payload;
}

</syntaxhighlight>

Prova Teorica 2009.01.14 - Revision history

Mrta: Created page with "Esercizio 1: Scrivere un monitor che implementi un buffer limitato (SIZE elementi) dove i messaggi abbiano associata una priorita'. I processi produttori richiamano pbb.enqueu..."