Java - watki

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

1 / 37

Programowanie współbie

zyk Java – w

tki

(streszczenie)

Paweł Rogali

ski

Instytut Informatyki, Automatyki i Robotyki
Politechniki Wrocławskiej

pawel.rogalinski

pwr.wroc.pl

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

2 / 37

Podstawowe poj

cia: procesy i w

tki

Proces

to wykonuj

cy si

program wraz z dynamicznie przydzielanymi mu przez

system zasobami (np. pami

operacyjn

, zasobami plikowymi). Ka

dy proces ma

własn

przestrze

adresow

Systemy wielozadaniowe pozwalaj

na równoległe (teoretycznie) wykonywanie

wielu procesów, z których ka

dy ma swój kontekst i swoje zasoby.

tek

to sekwencja działa

, która wykonuje si

w kontek

cie danego procesu

(programu)

dy proces ma co najmniej jeden wykonuj

cy si

tek. W systemach

wielow

tkowych proces mo

e wykonywa

równolegle (teoretycznie) wiele w

tków, które

wykonuj

jednej przestrzeni adresowej procesu.

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

3 / 37

Podstawowe poj

cia: procesy i w

tki

Równoległo

ść

działania w

tków osi

gana jest przez mechanizm przydzielania czasu

procesora poszczególnym wykonuj

cym si

tkom. Ka

dy w

tek uzyskuje dost

p do

procesora na krótki czas (kwant czasu), po czym „oddaje procesor” innemu w

tkowi.

Zmiana w

tku wykonywanego przez procesor mo

e dokonywa

na zasadzie:

współpracy

(cooperative multitasking), w

tek sam decyduje, kiedy odda

czas

procesowa innym w

tkom,

wywłaszczania

(pre-emptive multitasking), o dost

pie w

tków do procesora

decyduje systemowy zarz

dca w

tków, który przydziela w

tkowi kwant czasu

procesora, po upływie którego odsuwa w

tek od procesora i przydziela kolejny

kwant czasu innemu w

tkowi.

Java jest j

zykiem wieloplatformowym, a ró

ne systemy operacyjne stosuj

ró

mechanizmy udost

pniania w

tkom procesora. Programy wielow

tkowe powinny by

tak pisane, by działały zarówno w

rodowisku „współpracy” jak i „wywłaszczania”

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

4 / 37

Tworzenie i uruchamianie w

tków

Uruchamianiem w

tków i zarz

dzaniem nimi zajmuje si

klasa

Thread

Aby uruchomi

tek, nale

y utworzy

obiekt klasy

Thread

i dla tego obiektu wywoła

metod

start()

Kod wykonuj

cy si

jako w

tek – sekwencja działa

wykonuj

ca si

równolegle z

innymi działaniami programu – okre

lany jest przez obiekt implementuj

cy interfejs

Runnable

, który zawiera deklaracj

metody

run()

Metoda

run()

okre

la to co ma robi

tek.

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

5 / 37

Główne metody klasy

Thread

1. Uruchamianie i zatrzymywanie w

tków:

start

- uruchomienie w

tku,

stop

– zako

czenie w

tku (metoda niezalecana),

run

- kod wykonywany w ramach w

tku.

2. Identyfikacja w

tków:

currentThread

- metoda zwraca identyfikator w

tku bie

żą

cego,

setName

- ustawienie nazwy w

tku,

getName

-odczytanie nazwy w

tku,

isAlive

- sprawdzenie czy w

tek działa,

toString

- uzyskanie atrybutów w

tku.

3. Priorytety i szeregowanie w

tków:

getPriority

- odczytanie priorytetu w

tku,

setPriority

- stawienie priorytetu w

tku,

yield

- wywołanie szeregowania.

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

6 / 37

Główne metody klasy

Thread

c.d.

4. Synchronizacja w

tków:

sleep

zawieszenie wykonania w

tku na dany okres czasu,

join

- czekanie na zako

czenie innego w

tku,

wait

- czekanie w monitorze,

notify

- odblokowanie w

tku zablokowanego na monitorze,

notifyAll

- odblokowanie wszystkich w

tków zablokowanych na

monitorze,

interrupt

- odblokowanie zawieszonego w

tku,

suspend

- zablokowanie w

tku,

resume

- odblokowanie w

tku zawieszonego przez

suspend

setDaemon

- ustanowienie w

tku demonem,

isDaemon

- testowanie czy w

tek jest demonem.

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

7 / 37

Tworzenie w

tków

liwe s

dwa sposoby tworzenia nowego w

tku:

poprzez dziedziczenie klasy

Thread

poprzez implementacj

interfejsu

Runnable

Sposób drugi stosujemy wówczas, gdy klasa reprezentuj

ca w

tek musi dziedziczy

po innej ni

Thread

klasie (Java nie dopuszcza dziedziczenia wielobazowego).

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

8 / 37

Tworzenie w

tku – dziedziczenie klasy

Thread

Aby utworzy

tek jako klasa potomna od klasy

Thread

nale

1. Utworzy

now

klas

(na przykład o nazwie

Tklasa

) jako potomn

klasy

Thread

i nadpisa

metod

run()

klasy macierzystej. Metoda ta ma zawiera

kod do

wykonania w ramach tworzonego w

tku.

class TKlasa extends Thread {

....
void run() {
// Kod w

tku

}
....
}

2. Utworzy

obiekt nowej klasy

Tklasa

(na przykład

thr

TKlasa thr = new TKlasa(...);

3. Wykona

metod

start()

klasy

TKlasa

dziedziczon

z klasy macierzystej:

thr.start();

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

9 / 37

Tworzenie w

tku – dziedziczenie klasy

Thread

class

NowyWatek

extends

Thread

{

public

void

run()

{ System.out.println(

" Nowy watek : POCZATEK"

);

try

{

for

(

int

i = 5; i > 0; i--)

{ System.out.println(

" Nowy watek: "

+ i);

             Thread.sleep(500);
           }
         }

catch

(InterruptedException e) {}

System.out.println(

" Nowy watek : KONIEC"

);

}
}

class

GlownyWatek

{

public

static

void

main(String args[])

{ System.out.println(

" Glowny watek: POCZATEK"

);

System.out.println(

" Glowny watek: Tworze Nowy Watek"

);

NowyWatek nowyWatek =

new

NowyWatek();

System.out.println(

" Glowny watek: Uruchamiam Nowy watek"

);

nowyWatek.start();

try

{

for

(

int

i = 5; i > 0; i--)

{ System.out.println(

" Glowny watek: "

+ i);

              Thread.sleep(1000);
            }
          }

catch

(InterruptedException e) {}

System.out.println(

" Glowny watek: KONIEC"

);

}
}

tworzenie

nowego watka

uruchomienie

nowego watka

działanie

nowego watka

działanie

głównego

watka

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

11 / 37

Tworzenie w

tku – implement. interfejsu

Runnable

Aby utworzy

tek korzystaj

c z interfejsu

Runnable

nale

1. Utworzy

now

klas

(np. o nazwie

RKlasa

) dziedzicz

po interesuj

cej na

innej klasie (np. o nazwie

InnaKlasa

) i implementuj

interfejs

Runnable

. W

ramach tej nowej klasy utworzy

metod

run()

, która wykonywała b

dzie

żą

dane

czynno

ci.

class RKlasa extends InnaKlasa implements Runnable {
public void run() {
// Zawarto

ść

metody run

}
}

2. Utworzy

obiekt tej nowej klasy

Rklasa r1 = new RKlasa();

3. Utworzy

obiekt klasy

Thread

przekazuj

c obiekt wcze

niej utworzonej klasy

jako parametr konstruktora klasy

Thread

Thread t1 = new Thread(r1);

4. Uruchomi

watek wykonuj

c metod

start()

klasy

Thread

t1.start();

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

12 / 37

Tworzenie w

tku – implement. interfejsu

Runable

class

NowyWatek

implements

Runnable

{

public

void

run()

{ System.out.println(

" Nowy watek : POCZATEK"

);

try

{

for

(

int

i = 5; i > 0; i--)

{ System.out.println(

" Nowy watek: "

+ i);

             Thread.sleep(500);
           }
         }

catch

(InterruptedException e) {}

System.out.println(

" Nowy watek : KONIEC"

);

} }

class

GlownyWatek

{

public

static

void

main(String args[])

{ System.out.println(

" Glowny watek: POCZATEK"

);

System.out.println(

" Glowny watek: Tworze Nowy watek"

);

NowyWatek nowyWatek =

new

NowyWatek();

Thread thread =

new

Thread(nowyWatek);

System.out.println(

" Glowny watek: Uruchamiam Nowy watek"

);

thread.start();

try

{ for(int i = 5; i > 0; i--)

{ System.out.println(

" Glowny watek: "

+ i);

              Thread.sleep(1000);
            }
          }

catch

(InterruptedException e) {}

System.out.println(

" Glowny watek: KONIEC"

);

} }

działanie

nowego watka

tworzenie

nowego watka

uruchomienie

nowego watka

działanie

głównego

watka

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

13 / 37

czenie pracy w

tku

tek ko

czy prac

w sposób naturalny gdy zako

czy si

jego metoda

run()

Wykonanie metody

stop()

powoduje zatrzymanie innego w

tku. Gdy

zatrzymywany w

tek znajduje si

wewn

trz monitora to wej

cie do tego monitora

zostaje odblokowane. Metoda ta jest wycofana (istnieje ale u

ycie jej nie jest zalecane).

Powodem jest fakt

e wywołuj

c te metod

nie wiemy w jakim stanie jest zatrzymywany

tek. Gdy wykonuje jakie

krytyczne operacje mo

e pozostawi

obiekt w

nieprawidłowym stanie.

li chcemy programowo zako

czy

prac

tku, powinni

my zapewni

metodzie

run()

sprawdzanie warunku zako

czenia (ustalanego programowo) i je

warunek ten jest spełniony, spowodowa

wyj

cie z metody

run()

. Warunek

zako

czenia mo

e by

formułowany w postaci jakiej

zmiennej, która jest ustalana przez

inne fragmenty kodu programu (wykonywane w innym w

tku).

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

14 / 37

czenie pracy w

tku - przykład

class

NowyWatek

extends

Thread

{

boolean

zakoncz =

false

;

public

void

run()

{ System.out.println(

" Nowy watek : POCZATEK"

);

while

(zakoncz==

false

)

{

try

{ sleep(200);

}

catch

(InterruptedException e) {}

System.out.print(

" ."

);

}
System.out.println(

"\n Nowy watek : KONIEC"

);

}
}

class

GlownyWatek

{

public

static

void

main(String args[])

{ System.out.println(

" Glowny watek: POCZATEK"

);

System.out.println(

" Glowny watek: Tworze Nowy watek"

);

NowyWatek nowyWatek =

new

NowyWatek();

nowyWatek.start();

try

{ Thread.sleep(10000);

}

catch

(InterruptedException e) {}

nowyWatek.zakoncz =

true

;

try

{ Thread.sleep(2000);

}

catch

(InterruptedException e) {}

System.out.println(

" Glowny watek: KONIEC"

);

}
}

testowanie warunku

zako

czenia watka

wymuszenie warunku

zako

czenia watka

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

16 / 37

Stany w

tków

tek mo

e znajdowa

w jednym z czterech stanów:

utworzony

(ang. new thread) - obiekt w

tku został ju

utworzony ale nie

wykonano metody

start()

, a wi

c w

tek nie jest jeszcze szeregowany,

wykonywalny

(ang. runnable) - W

tek posiada wszystkie zasoby aby by

wykonywany. B

dzie wykonywany gdy tylko procedura szereguj

ca przydzieli

mu procesor,

zablokowany

(ang. blocked) -W

tek nie mo

e by

wykonywany gdy

brakuje

mu pewnych zasobów. Dotyczy to w szczególno

ci operacji synchronizacyjnych

tek zablokowany na wej

ciu do monitora, operacje

wait

sleep

join

) i

operacji wej

cia wyj

cia,

zako

czony

(ang. dead) - Stan po wykonaniu metody

stop()

. Zalecanym

sposobem ko

czenia w

tku jest zako

czeni metody

run()

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

18 / 37

Stany w

tków

Przej

cie od stanu

wykonywalny

zablokowany

nast

puje gdy:

1. w

tek chce wej

ść

do zablokowanego monitora

2. wykonana została metoda

wait()

join()

suspend()

3. wywołano metod

sleep(...)

4. w

tek wykonał operacj

wej

cia / wyj

cia.

Powrót od stanu

zablokowany

wykonywany

nast

puje gdy:

1. monitor został odblokowany

2. inny w

tek wykonał operacja odblokowania zablokowanego w

tku – wywołał

metod

notify()

notifyAll()

resume()

interrupt()

3. gdy w

tek zako

czył wykonywanie metody

sleep()

– upłyn

ł zadany interwał

czasu.

4. je

eli w

tek czekał na zako

czenie operacji wej

cia / wyj

cia – operacja ta si

zako

czyła

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

19 / 37

Synchronizacja w

tków - przykład

Pytanie:

Jak

warto

ść

zwróci metoda

balance()

class Balance

{

private int number = 0;

public int balance()

{ number++;

number--;

return number;

}

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

20 / 37

Synchronizacja w

tków – przykład c.d.

Zmiany warto

ci zmiennej

number

gdy wykonywany jest tylko jeden w

tek:

Warto

ci zmiennej

number

wykonywane instrukcje

w w

tku

. . .

balance(){

number++;

number--;

return number;
}

. . .

zwróci

warto

ść

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

21 / 37

Synchronizacja w

tków – przykład c.d.

Zmiany warto

ci zmiennej

number

gdy wykonywane s

dwa w

tki:

Warto

ci zmiennej

number

wykonywane instrukcje

w pierwszym w

tku

wykonywane instrukcje

w drugim w

tku

. . .

balance(){

number++;

number--;

return number;
}

. . .

balance(){

number++;

number--;

return number;
}

. . .

zwróci

warto

ść

zwróci

warto

ść

wywłaszczenie

pierwszego

tka

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

22 / 37

Synchronizacja w

tków – przykład c.d.

Zmiany warto

ci zmiennej

number

gdy wykonywane s

dwa w

tki:

Warto

ci zmiennej

number

wykonywane instrukcje

w pierwszym w

tku

wykonywane instrukcje

w drugim w

tku

. . .

balance(){

number++;

. . .

balance(){

number++;

number--;

return number;
}

. . .

number--;

return number;
}

. . .

zwróci

warto

ść

wywłaszczenie

pierwszego

tka

zwróci

warto

ść

wywłaszczenie

drugiego w

tka

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

23 / 37

Synchronizacja w

tków

– przykład c.d.

Zawsze musimy si

liczy

z tym,

e w

tki operuj

ce na współdzielonych zmiennych

mog

wywłaszczone w trakcie operacji (nawet pojedynczej) i wobec tego stan

współdzielonej zmiennej mo

e okaza

niespójny.

Testowanie programów wielow

tkowych jest trudne, bowiem mo

emy wiele

razy otrzyma

wyniki, które wydaj

wiadczy

o poprawno

ci programu,

a przy kolejnym uruchomieniu oka

e si

e wynik jest nieprawidłowy.

Wyniki uruchamiania programów wielow

tkowych mog

tak

e ró

na ró

nych platformach systemowych.

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

24 / 37

Synchronizacja w

tków

Komunikacja mi

dzy w

tkami opiera si

wspólnej pami

. W takim przypadku

wyst

puje zjawisko wy

cigów.

cigi

(ang. race conditions) – wynik działania procedur wykonywanych przez

tki zale

y od kolejno

ci ich wykonania.

Gdy kilka w

tków ma dost

p do wspólnych danych i przynajmniej jeden je

modyfikuje wyst

puje konieczno

ść

synchronizowania dost

pu do wspólnych danych.

Synchronizacja

jest mechanizmem, który zapewnia,

e kilka wykonuj

cych si

tków:

nie b

dzie równocze

nie działa

na tym samym obiekcie,

nie b

dzie równocze

nie wykonywa

tego samego kodu.

Kod, który mo

e by

wykonywany w danym momencie tylko przez jeden w

tek,

nazywa si

sekcj

krytyczn

. W Javie sekcje krytyczne wprowadza si

jako bloki lub

metody synchronizowane.

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

25 / 37

Synchronizacja w

tków - monitory

dy egzemplarz klasy

Object

i jej podklas posiada

monitor

(ang. lock), który

ogranicza dost

p do obiektu. Blokowanie obiektów jest sterowane słowem kluczowym

synchronized

Synchronizacja w Javie mo

e by

wykonana na poziomie:

metod – słowo kluczowe

synchronized

wyst

puje przy definiowaniu metody:

public synchronized int balance()

{...}

instrukcji - słowo kluczowe

synchronized

wyst

puje przy definiowaniu bloku

instrukcji:

    synchronized( number )
      {  number++;
         number--;
      }

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

26 / 37

Synchronizacja w

tków

Kiedy w

tek wywołuje na rzecz jakiego

obiektu metod

synchronizowan

automatycznie zamykany jest monitor (obiekt jest zajmowany przez w

tek). Inne w

tki

usiłuj

ce wywoła

na rzecz tego obiektu metod

synchronizowan

(niekoniecznie t

sam

) lub usiłuj

ce wykona

instrukcj

synchronized

z podan

referencj

zaj

tego obiektu s

blokowane i czekaj

na zako

czenie wykonywania metody lub

instrukcji

synchronized

przez w

tek, który zaj

ł obiekt (zamkn

ł monitor).

Dowole zako

czenie wykonywania metody synchronizowanej lub instrukcji

synchronized

zwalnia monitor, daj

c czekaj

cym w

tkom mo

liwo

ść

dost

pu do

obiektu.

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

27 / 37

Koordynacja w

tków

Koordynacja w

tków polega na zapewnieniu wła

ciwej kolejno

ci działa

wykonywanych przez ró

ne w

tki na wspólnym zasobie. Do koordynacji w

tków stosuje

nast

puj

ce metody:

wait()

notify()

notifyAll().

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

28 / 37

Metoda

wait()

public final void wait();

public final void wait(long timeout);

public final void wait(long timeout,int nanos)

throws InterruptedException

Wykonanie metody powoduje zawieszenie bie

żą

cego w

tku do czasu gdy inny

watek nie wykona metody

notify()

lub

notifyAll()

odnosz

cej si

do w

tku, który

wykonał

wait()

. W

tek wykonuj

wait(...)

musi by

w posiadaniu monitora

dotycz

cego synchronizowanego obiektu. Wykonanie

wait(...)

powoduje zwolnienie

monitora.

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

29 / 37

Metoda

notify()

public final void notify();

Metoda powoduje odblokowanie jednego z w

tków zablokowanych na monitorze

pewnego obiektu poprzez

wait()

. Który z czekaj

cych w

tków b

dzie odblokowany nie

jest w definicji metody okre

lone.

Odblokowany w

tek nie b

dzie natychmiast wykonywany – musi on jeszcze

zaczeka

zwolniona b

dzie przez bie

żą

cy w

tek blokada monitora. Odblokowany

tek b

dzie konkurował z innymi o nabycie blokady monitora. Metoda mo

e by

wykonana tylko przez w

tek, który jest wła

cicielem zajmuje monitor obiektu.

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

30 / 37

Metoda

notifyAll()

public final void notifyAll()

Metoda powoduje odblokowanie wszystkich w

tków zablokowanych na monitorze

pewnego obiektu poprzez uprzednie wykonanie

wait()

tki b

jednak czekały a

tek bie

żą

cy nie zwolni blokady monitora.

Odblokowane w

tki b

konkurowały o nabycie blokady monitora.

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

31 / 37

Przykład koordynacji: Problem producent - konsument

Kilku producentów i konsumentów korzysta ze wspólnego zasobu jakim jest bufor.

dy producent co pewien czas generuje liczby i umieszcza je w buforze.

dy konsument co pewien czas pobiera liczb

z bufora i wy

wietla j

ekranie.

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

32 / 37

Przykład koordynacji: Problem producent - konsument

Ograniczenia:

1. Z bufora mo

e korzysta

w jedej chwili tylko jeden producent lub konsument,

2. Producent mo

e umie

liczb

w buforze tylko wówczas, gdy bufor jest pusty.

W przeciwnym wypadku Producent musi czeka

, a

konsument zwolni miejsce

w buforze.

3. Konsument mo

e pobra

liczb

z bufra tylko wtedy, gdy bufor nie jest pusty.

W przeciwnym wypadku konsument musi czeka

ąż

jaki

producent umie

ci w

buforze liczb

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

33 / 37

Klasa

Producent

public class Producent extends Thread
{
   private Bufor buf;
   private int number;

   public Producent(Bufor c, int number)
   {  buf = c;
      this.number = number;
   }

   public void run()
   { for (int i = 0; i < 10; i++)
       {

buf.put(i);

          System.out.println("Producent #" +
          this.number + " put: " + i);
          try {
                sleep((int)(Math.random() * 100));
              } catch (InterruptedException e) { }
       }
   }
}

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

34 / 37

Klasa

Konsument

public class Konsument extends Thread
{
   private Bufor buf;
   private int number;

   public Konsument(Bufor c, int number)
   {  buf = c;
      this.number = number;
   }

   public void run()
   {  int value = 0;
      for (int i = 0; i < 10; i++)
        {

value = buf.get();

           System.out.println("Konsument #" +
           this.number + " got: " + value);
        }
   }
}

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

36 / 37

Klasa

Bufor

– metoda

get()

public class Bufor
{
   private int contents;
   private boolean available = false;

   public synchronized int get()
   {
     while (available == false)
        {
          try {

wait();

              } catch (InterruptedException e) { }
        }
     available = false;

notifyAll();

return contents;
}

zyka Java – w

tki

Autor: Paweł Rogali

ski – Instytut Informatyki, Automatyki i Robotyki PWr

37 / 37

Klasa

Bufor

– metoda

put()

public synchronized void put(int value)
{
   while (available == true)
      {
        try {

wait();

            } catch (InterruptedException e) { }
      }

   contents = value;
   available = true;

notifyAll();

}