Esperimenti con semafori e monitor in Python - Revision history

Renzo: /* produttore consumatore con i monitor */

2016-10-27T18:38:07Z

produttore consumatore con i monitor

Renzo: /* produttore consumatore con i monitor */

2016-10-27T18:35:55Z

produttore consumatore con i monitor

Renzo: /* Monitor in Python */

2016-10-27T18:35:32Z

Monitor in Python

Renzo: /* produttore consumatore con i monitor */

2016-10-27T15:59:55Z

produttore consumatore con i monitor

Renzo: /* produttore consumatore con i monitor */

2016-10-27T15:59:38Z

produttore consumatore con i monitor

Renzo: /* produttore consumatore con i monitor */

2016-10-27T15:58:59Z

produttore consumatore con i monitor

Renzo: /* produttore consumatore con i semafori */

2016-10-27T15:52:54Z

produttore consumatore con i semafori

Renzo: Created page with "Ho messo a vostra disposizione alcuni sorgenti che implementano in Python 3 le astrazioni di semaforo e monitor come le abbiamo viste (o vedremo presto) a lezione. Per il supp..."

2016-10-27T15:37:16Z

Created page with "Ho messo a vostra disposizione alcuni sorgenti che implementano in Python 3 le astrazioni di semaforo e monitor come le abbiamo viste (o vedremo presto) a lezione. Per il supp..."

New page

Ho messo a vostra disposizione alcuni sorgenti che implementano in Python 3 le astrazioni di semaforo e monitor come le abbiamo viste (o vedremo presto) a lezione. Per il supporto di multithreading si usa la libreria standard ''threading''.

Anche Python (purtroppo) definisce semafori non fair e variabili di condizione di tipo ''signal&continue''.
Questi sorgenti implementano (SE&O) semafori fair e monitor con condizioni ''signal-urgent''.

Ho messo il materiale in [http://www.cs.unibo.it/~renzo/so/tools/pysm.tgz questo file].

== Semafori ==

Il sorgente ''semaphore.py'' definisce la classe ''semaphore'' che ha due metodi ''P()'' e ''V()'' (non l'avreste mai detto...).

Quindi un semaforo mutex si definisce
<syntaxhighlight lang=python>
mutex = semaphore(1)
</syntaxhighlight>

e si usa così
<syntaxhighlight lang=python>
mutex.P()
# critical section
mutex.V()
</syntaxhighlight>

== produttore consumatore con i semafori ==

Il file ''pc_sema.py'' implementa una soluzione del problema dei produttori/consumatori in python.

La funzione ''safeprint'' serve per poter ricevere stampe leggibili perché la print stessa non è atomica.
(usano una print al posto della safeprint si possono osservare le stampe dei diversi thread mischiate fra loro).
<syntaxhighlight lang=python>
mutex = semaphore(1)
def safeprint(*args,**kwargs):
mutex.P()
print(*args,**kwargs)
mutex.V()
</syntaxhighlight>

@@ Line 114: / Line 114: @@
 </syntaxhighlight>
-La classe pcmon (producer comsumer monitor) &egrave; la seguente:
+La classe pcmon (producer consumer monitor) &egrave; la seguente:
 <syntaxhighlight lang=python>
 class pcmon(monitor):
@@ Line 139: / Line 139: @@
      return rval
 </syntaxhighlight>
 La sintassi &egrave; molto simile a quella usata negli esercizi teorici. Occorre solo ricordarsi di:
 * concatenare il costruttore della classe monitor
 * indicare il decoratore entry ad ogni procedure entry (altrimenti non c'&egrave; la sezione critica).

@@ Line 105: / Line 105: @@
 class safeprint(monitor):
    def __init__(self):
-     super().__init__(self)
+     super().__init__()
    @entry
@@ Line 118: / Line 118: @@
 class pcmon(monitor):
    def __init__(self, size=1):
-     super().__init__(self)
+     super().__init__()
      self.ok2write = condition(self)
      self.ok2read = condition(self)

@@ Line 81: / Line 81: @@
 class mymonitor(monitor):
    def __init__(self):
-     super().__init__(self)
+     super().__init__()
 #   definizione degli attributi dell'oggetto per esempio una var. di condizione
      mycond = condition(self)

@@ Line 114: / Line 114: @@
 </syntaxhighlight>
-La classe pcmon (producer comsumer monitor) &egrave la seguente:
+La classe pcmon (producer comsumer monitor) &egrave; la seguente:
 <syntaxhighlight lang=python>
 class pcmon(monitor):

@@ Line 138: / Line 138: @@
      self.ok2write.signal()
      return rval
-<syntaxhighlight>
+</syntaxhighlight>
 La sintassi &egrave; molto simile a quella usata negli esercizi teorici. Occorre solo ricordarsi di:
 * concatenare il costruttore della classe monitor
 * indicare il decoratore entry ad ogni procedure entry (altrimenti non c'&egrave; la sezione critica).

← Older revision		Revision as of 15:58, 27 October 2016
Line 98:		Line 98:

	== produttore consumatore con i monitor ==		== produttore consumatore con i monitor ==
		+
		+	Anche in questo caso è stata scritta una safeprint per avere print in critical section.
		+	&Egrave un esempio minimale di uso dei monitor visto che la mutua esclusione viene fornita come caratteristca standard delle procedure entry.
		+
		+	<syntaxhighlight lang=python>
		+	class safeprint(monitor):
		+	def __init__(self):
		+	super().__init__(self)
		+
		+	@entry
		+	def print(self, args,*kwargs):
		+	print(args,*kwargs)
		+
		+	safeprint = safeprint().print
		+	</syntaxhighlight>
		+
		+	La classe pcmon (producer comsumer monitor) &egrave la seguente:
		+	<syntaxhighlight lang=python>
		+	class pcmon(monitor):
		+	def __init__(self, size=1):
		+	super().__init__(self)
		+	self.ok2write = condition(self)
		+	self.ok2read = condition(self)
		+	self.buf = []
		+	self.size = size
		+
		+	@entry
		+	def put(self, val):
		+	if len(self.buf) >= self.size:
		+	self.ok2write.wait()
		+	self.buf.append(val)
		+	self.ok2read.signal()
		+
		+	@entry
		+	def get(self):
		+	if len(self.buf) == 0:
		+	self.ok2read.wait()
		+	rval = self.buf.pop(0)
		+	self.ok2write.signal()
		+	return rval
		+	<syntaxhighlight>
		+
		+	La sintassi è molto simile a quella usata negli esercizi teorici. Occorre solo ricordarsi di:
		+	* concatenare il costruttore della classe monitor
		+	* indicare il decoratore entry ad ogni procedure entry (altrimenti non c'è la sezione critica).

@@ Line 25: / Line 25: @@
 Il file ''pc_sema.py'' implementa una soluzione del problema dei produttori/consumatori in python.
 La funzione ''safeprint'' serve per poter ricevere stampe leggibili perch&eacute; la print stessa non &egrave; atomica.
@@ Line 35: / Line 40: @@
    mutex.V()
 </syntaxhighlight>