Prova teorica 2014.06.03 - Revision history

GabrieleCalarota at 14:45, 27 June 2017

2017-06-27T14:45:12Z

FedericoB: Aggiunta soluzione

2017-06-14T12:35:33Z

Aggiunta soluzione

S.G: Esercizio message passing c.2

2016-12-04T09:35:20Z

Esercizio message passing c.2

New page

Testo: [http://www.cs.unibo.it/~renzo/so/compiti/2014.06.03.tot.pdf]

== Esercizio c.2 ==

Siano dati 4 processi:
<syntaxhighlight lang="Python">
prchar=”IATL”
Process i: i=range(4)
while True:
sync(i)
print(prchar[i])
</syntaxhighlight>

Scrivere la funzione sync in modo che in un sistema di processi a memoria privata, usando message passing asincrono, l'unico
output possibile sia la stringa di lunghezza infinita: “ITALIAITALIAITALIA....”

'''Descrizione soluzione'''

Solo il processo 2 (lettera T) permette di iniziare la sincronizzazione dei processi.

Oltre al processo 2 anche il processo 1 (lettera A) permette di riavviare la sequenza.

''Nella descrizione di seguito chiameremo T il processo incaricato a stampare tale lettera, e cosi anche per gli altri.''

<syntaxhighlight lang="Python">
def sync(i):
if i == 0: # Processo 0 (processo I)
mittente = recv(*) # Aspetto un messaggio da T, L o A
if mittente == 2 or mittente == 1: # Se il mittente è il processo T o A (avvio o riavvio sequenza)
send(2, 0) # Invio un messaggio al processo T

elif mittente == 3: # Se il mittente è il processo L
send(1, 0) # Invio un messaggio al processo A

elif i == 1: # Processo 1 (processo A)
mittente = recv(*) # Aspetto un messaggio dal processo T o I
if mittente == 0: # Se il mittente è il processo I
send(0, 1) # Invio un messaggio al processo I (riavvio la sequenza)
elif mittente == 2: # Se il mittente è il processo T
send(3, 1) # Invio un messaggio al processo L

elif i == 2: # Processo 2 (processo T)
send (0, 2) # Invio un messaggio al processo I (Avvia la sequenza)
mittente = recv(0) # Aspetto un messaggio dal processo I
if mittente == 0: # Se il mittente è il processo I
send(1, 2) # Invio un messaggio al processo A

elif i == 3: # Processo 3 (processo L)
mittente = recv(1) # Aspetto un messaggio dal processo A
if mittente == 1: # Se il mittente è il processo A
send(0, 3) # Invio un messaggio al processo I
</syntaxhighlight>
Una volta avviato T invierà un messaggio a I e si bloccherà in attesa di I.

Il processo I in attesa riceverà un messaggio da T, allora sbloccherà T e stamperà I.

A questo punto il processo T invierà un messaggio ad A, e stamperà T.

A aspetterà messaggi da più mittenti, in questo caso riceverà un messaggio da T, invierà un messaggio ad L e stamperà A.

L aspetterà il messaggio da A che appena ricevuto invierà un messaggio ad I, e stamperà L.

Il processo I in attesa, riceverà un messaggio da L sbloccandosi invierà un messaggio ad A e stamperà I.

A ancora una volta in attesa, riceverà un messaggio da I, risponderà ad I e stamperà A.

I riceverà un messaggio da A, e riavvierà la sequenza.
[[User:S.G|S.G]] ([[User talk:S.G|talk]]) 10:35, 4 December 2016 (CET)

← Older revision		Revision as of 14:45, 27 June 2017
Line 1:		Line 1:
	Testo: [http://www.cs.unibo.it/~renzo/so/compiti/2014.06.03.tot.pdf]		Testo: [http://www.cs.unibo.it/~renzo/so/compiti/2014.06.03.tot.pdf]
		+
		+	== Esercizio c.1 ==
		+	=== Soluzione di G.C. ===
		+	<syntaxhighlight lang ="C">
		+	int wait_enter[N][2] = {0,0,0,0,0,0,0,0,0,...,0}
		+	int wait_exit[N] = {0,0,0, ... , 0}
		+
		+	int n = 0;
		+
		+	monitor sabelev{
		+
		+	int current_floor = NULL;
		+	int current_dir = NULL;
		+	condition ok2enter[N][2], ok2exit[N];
		+	procedure entry atfloor(floor, dir){
		+	current_floor = floor;
		+	current_dir = dir;
		+	if (wait_enter[floor][dir]>0){
		+	ok2enter[floor][dir].signal();
		+	}
		+	if (wait_exit[floor]>0){
		+	ok2exit[floor].signal();
		+	}
		+	//elevator is moving from floor to floor+1 (or -1)
		+	current_floor = NULL;
		+	}
		+	procedure entry enter(from, to){
		+	int dir = from>to ? down : up;
		+	if (current_floor != from) \|\| (current_dir != dir){
		+	wait_enter[from][dir]++;
		+	ok2enter[from][dir].wait();
		+	wait_enter[from][dir]--;
		+	}
		+	//process enter in the elevator
		+	n++;
		+	//wakes up the processes that are in this floor and going in its direction
		+	if (wait_enter[from][dir]>0){
		+	ok2enter[from][dir].signal();
		+	}
		+	}
		+	procedure entry exit(from,to){
		+	if (current_floor != to){
		+	wait_exit[to]++;
		+	ok2exit[to].wait();
		+	wait_exit[to]--;
		+	}
		+	//exit from the elevator
		+	n--;
		+	//wakes up the processes that have to exit on this floor
		+	if (wait_exit[to]>0){
		+	ok2exit[to].signal();
		+	}
		+	}
		+	}
		+	</syntaxhighlight>
		+

	== Esercizio c.2 ==		== Esercizio c.2 ==

@@ Line 15: / Line 15: @@
 output possibile sia la stringa di lunghezza infinita: “ITALIAITALIAITALIA....”
-'''Descrizione soluzione'''
+===Soluzione di S.G===
 Solo il processo 2 (lettera T) permette di iniziare la sincronizzazione dei processi.
@@ Line 67: / Line 67: @@
 I riceverà un messaggio da A, e riavvierà la sequenza.
 [[User:S.G|S.G]] ([[User talk:S.G|talk]]) 10:35, 4 December 2016 (CET)