3. cvičenie – Vypínač, P-K, Č-Z ?

1 Vypínač

Implementujte ADT Lightswitch. ADT Lightswitch nech poskytuje 2 metódy: lock a unlock podľa nasledovnej špecifikácie:

lock(semaphore)
unlock(semaphore)

Interný stav ADT Lightswitch je daný počítadlom counter a mutexom mutex, ktorý chráni integritu počítadla.

Správanie ADT Lightswitch:

Ak vlákno zavolá metódu lock, a toto vlákno je prvým, ktoré sa pokúša „dostať do miestnosti“, nech vyvolá nad semaforom, ktorý je argumentom funkcie lock, operáciu wait().
Ak vlákno zavolá metódu unlock, a toto vlákno je posledným, ktoré sa pokúša „dostať z miestnosti“, nech vyvolá nad semaforom, ktorý je argumentom funkcie unlock, operáciu signal().

Na jednoduchom príklade overte funkčnosť svojej implementácie. Tento ADT správne využite v niektorej z nasledovných úloh.

2 Producent-Konzument

Implementujte riešenie problému Konzument-Producent. Experimentujte s rôznymi nastaveniami systému:

čas produkcie výrobku,
čas spracovania výrobku,
počet konzumentov,
počet producentov,
veľkosť úložiska (skladu).

Skúste experimentálne zistiť, aké parametre sú optimálne pre váš systém. Kritériom optimality nech sú:

Počet vyrobených výrobkov za jednotku času (v akom vzťahu sú čas produkcie výrobku, veľkosť úložiska, počet producentov a počet konzumentov?),
počet spracovaných výrobkov za jednotku času (v akom vzťahu sú čas spracovania výrobku, veľkosť úložiska, počet producentov a počet konzumentov?).

V prípade experimentov priemerujte hodnoty 10 opakovaní experimentu pri rovnakých nastaveniach systému; grafy vykresľujte aspoň pre 100 rôznych nastavení modelovaného systému.

3 Čitatelia-Zapisovatelia

Podobne ako v prípade problematiky Producentov-Konzumentov, aj tu experimentujte s rôznymi nastaveniami systému. Implementujte dve verzie riešenia tohto problému:

bez riešenia vyhladovenia zapisovateľov,
s riešením problému vyhladovenia zapisovateľov.

Experimentujte s nasledovnými parametrami systému, a hľadajte medzi nimi závislosti:

počet čitateľov,
počet zapisovateľov,
doba čítania,
doba zápisu.
Pre aký počet čitateľov s danou priemernou dobou čítania sa prejavuje problém vyhladovenia?
Má počet zapisovateľov vplyv na schopnosť čitateľov dostať sa k údajom a prečítať ich?
Je možné, aby sa prejavilo vyhladovenie aj u čitateľov?
Ak doplníme implementáciu o turniket, aby neprišlo k vyhladoveniu zapisovateľov, vieme rozhodnúť, ktorý z kódov zo záveru prednášky je lepší?
Pre daný počet čitateľov, priemernú dobu čítania, priemernú dobu zápisu vieme určit optimálny počet zapisovateľov?
Ak máme danú priemernú dobu zápisu a priemernú dobu čítania, vieme vykresliť graf závislosti medzi počtom zapisovateľov a optimálnym počtom čitateľov (aby sme mohli nasadiť čo najviac čitateľov bez toho, aby prichádzalo k vyhladoveniu zapisovateľov). Vieme urobiť experiment, v ktorom sa bude meniť aj priemerná doba zápisu (mali by sme dostať trojrozmerný graf)?

Podobne ako pri probléme producent-konzument, aj pri týchto experimentoch opakujte merania aspoň 10x pre rovnaké nastavenie systému, a výsledky priemerujte; grafy vykresľujte aspoň pre 100 rôznych nastavení modelovaného systému.

Pri písaní kódu dbajte na prehľadnosť, samočitateľnosť, modularitu a znovupoužiteľnosť kódu. Dodržiavajte štandard PEP8. Vhodne využívajte možnosť komentovania kódu, viď štandard PEP257.

Do experimentov vhodným spôsobom vnášajte náhodnosť. Napr. kód zapisovateľa by mohol mať nasledovnú štruktúru:

from time import sleep
from random import randint
 
 
def writer_thread(thread_id, shared):
    while True:
        # pred kazdym pokusom o zapis pocka v intervale <0.0; 1> sekundy
        sleep(randint(0, 10)/10)

        shared.roomEmpty.wait()
        # simulujeme dlzku zapisu v intervale <0.3; 0.7> sekundy
        sleep(0.3 + randint(0, 4)/10)
        shared.room_empty.signal()

				
					
				1
2
3
4
5
6
7
8
9
10
11
12
13

						from time import sleep
from random import randint
 
 
def writer_thread(thread_id, shared):
    while True:
        # pred kazdym pokusom o zapis pocka v intervale <0.0; 1> sekundy
        sleep(randint(0, 10)/10)
 
        shared.roomEmpty.wait()
        # simulujeme dlzku zapisu v intervale <0.3; 0.7> sekundy
        sleep(0.3 + randint(0, 4)/10)
        shared.room_empty.signal()

					

			

Pre zopakovanie uvádzame aj kód vytvorenia vlákien.

from fei.ppds import Thread, Semaphore, print
 
 
class Shared():
    def __init__(self):
        self.room_empty = Semaphore(1)
 
 
"""
Vytvorime vlakna, ktore chceme synchronizovat.
Nezabudnime vytvorit aj zdielane synchronizacne objekty,
a dat ich ako argumenty kazdemu vlaknu, ktore chceme pomocou nich
synchronizovat.
"""

shared = Shared()
threads = []

for i in range(10):
    t = Thread(writer_thread, f"Writer {i}", shared)
    threads.append(t)

for t in threads:
    t.join()

				
					
				1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

						from fei.ppds import Thread, Semaphore, print
 
 
class Shared():
    def __init__(self):
        self.room_empty = Semaphore(1)
 
 
"""
Vytvorime vlakna, ktore chceme synchronizovat.
Nezabudnime vytvorit aj zdielane synchronizacne objekty,
a dat ich ako argumenty kazdemu vlaknu, ktore chceme pomocou nich
synchronizovat.
"""
 
shared = Shared()
threads = []
 
for i in range(10):
    t = Thread(writer_thread, f"Writer {i}", shared)
    threads.append(t)
 
for t in threads:
    t.join()

					

			

Vypracovanie úloh z cvičenia na domácu úlohu

Vyberte si jednu z úloh P-K alebo R-W.

V prípade P-K si zvoľte jedno z kritérií optimalizačnej úlohy (počet vyrobených výrobkov za jednotku času alebo počet spracovaných výrobkov za jednotku času). Vypracujte a dôsledne zdokumentujte experiment optimalizácie parametrov vášho systému.
Ak si zvolíte problematiku R-W, môžete (ale nemusíte) vypracovať obe verzie (s/bez vyhladovenia). Ovšem vzhľadom na Vašu voľbu vhodne experimentujte s nastaveniami systému a hľadajte závislosti podľa návodu. V dokumentácií určite odpovedajte na otázky 5, 7, 9 alebo 5, 7, 10.