Przetwarzanie współbieżne
Wojciech Kupczyk
94415
Laboratorium 5
Data
3.04.2014, 14:30
Cele laboratorium:
synchronizacja wątków w Javie
Ad. 1.
Zadanie polegało na zaimplementowaniu symulacji pubu w Javie. Projekt składa się z 3 klas:
Klient, Pub, Main. Poniżej przedstawiam kody źródłowe zawarte w każdym z tych plików,
oraz fragment przykładowego wydruku.
Pub.java:
6
public
class
Pub {
7
8
int
ilKlientow
,
ilKufli
;
9
int
[]
tabKufli
;
10
11
//konstruktor Pubu
12
public
Pub(
int
ilKlientow,
int
ilKufli) {
13
this
.
ilKufli
= ilKufli;
14
this
.
ilKlientow
= ilKlientow;
15
tabKufli
=
new
int
[
this
.
ilKufli
];
16
for
(
int
i = 0; i <
this
.
ilKufli
; i++) {
17
tabKufli
[i] = 1;
//puste kufle
18 }
19 }
20
21
// Zajecie wolnego kufla przez klienta, lub oczekiwanie na zwolnienie jednego z zajetych kufli.
22
public
synchronized
void
zabierzKufel(Klient klient) {
23 System.
out
.println(klient.
idKlienta
+
" klient oczekuje na wolny kufel."
);
24
while
(
true
) {
25
try
{
26
for
(
int
i = 0; i <
ilKufli
; i++)
//petla po wszystkich kuflach
27 {
28
//jesli dany kufel jest wolny to zabieramy
29
if
(
tabKufli
[i] == 1) {
30
tabKufli
[i] = 0;
31 klient.
idZajetegoKufla
= i;
32
break
;
33 }
34 }
35
if
(klient.
idZajetegoKufla
== -1) {
36 wait();
// jesli nie znaleziono zadnego wolnego kufla to czekamy
37 }
else
{
38
break
;
39 }
40 }
catch
(InterruptedException ex) {
41 Logger.getLogger(Pub.
class
.getName()).log(Level.
SEVERE
,
null
, ex);
42 System.
out
.println(
"Wyjatek w metodzie zabierzKufel !!! "
);
43 }
44 }
45 System.
out
.println(klient.
idKlienta
+
" klient dostal kufel "
+ (klient.
idZajetegoKufla
+ 1));
46 }
47
48
//nalewanie piwa, klient jako argument
49
public
synchronized
void
nalewanie(Klient klient) {
50
try
{
