Proz-S6

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 1

6. W

tki

6.1 Poj

cie w

tku programu

6.2 Klasy

Timer

TimerTask

6.3 Klasa

Thread

6.4 Synchronizacja pracy w

tków

6.5 Grupowanie w

tków

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 2

6.1 W

tki programu

1) Poj

cie w

tku

tek ("thread")

to osobna sekwencja wykonania instrukcji programu

w ramach jednego programu, wykonywana

współbie

nie

z innymi

tkami tego programu.

W odró

nieniu od procesu w

tek posiada jedynie swój

kontekst

wykonania – stos, rejestry i licznik rozkazów

– ale współdzieli on

pami

ęć

dynamiczn

(„stert

”) programu z innymi w

tkami tego

programu.
W

tki znajduj

zastosowanie tam, gdzie rozwi

zanie zadania mo

zrealizowane przez

algorytm równoległy

. Przykłady zada

dla

tków: obliczenie liczb pierwszych, sortowanie danych, wykonywanie

animacji, itp.
Dzi

tkom

realizujemy

mechanizm

asynchronicznego

wywoływania i wykonywania metod w

ramach jednego programu.

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 3

6.2 Klasy

Timer

TimerTask

Klasy

java.util.Timer

(

extends Object

)

TimerTask

(extends Object

implements Runnable)

yteczne do wyznaczania czasu wznowienia

tku po pewnej przerwie.

Uwaga: dla programu posiadaj

cego GUI realizowany w

Swing

-u

odpowiedni

klas

jest

javax.swing.Timer

zamiast

java.util.Timer

Metody klasy

Timer

przeznaczone do

wybierania zada

// Wykonanie zadania po upływie czasu lub o dokładnej porze:

schedule (TimerTask task, long delay)

schedule (TimerTask task, Date time)

// Wielokrotne wznawianie wykonania co okres czasu:
// - "mi

kkie" dotrzymanie okresu – gdy poprzednie wykonanie si

zako

czyło

schedule (TimerTask task, long delay, long okres)

schedule (TimerTask task, Date time, long okres)

//- ustalony na sztywno okres –bez wzgl

du na zako

czenie poprzedniego

scheduleAtFixedRate (TimerTask task, long delay, long okres)

scheduleAtFixedRate (TimerTask task, Date firstTime, long okres)

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 4

Jednokrotne asynchroniczne wykonanie zadania

po upływie czasu

Przykład.

Zastosujemy klasy

Timer

TimerTask

dla asynchronicznego

wykonania zadania po upływie 5 sekund.

import java.util.Timer;
import java.util.TimerTask;
public class Przypomnienie

{

// Klasa główna naszego zadania

Timer timer;
public Przypomnienie(int sekundy) {

// Konstruktor klasy głównej

timer = new Timer();

// (3) Tworzymy w

tek - obiekt klasy

Timer

timer.schedule(new PrzypomTimerTask(), sekundy*1000);

// (4)

// (4) Tworzymy obiekt naszego typu pochodnego od

TimerTask

// wybieramy go do wykonania po upływie 5000 ms

}

// W klasie głównej definiujemy klas

wewn

trzn

// (1) definiujemy własn

klas

pochodn

TimerTask

class PrzypomTimerTask extends TimerTask {
public void run() {

// (2) Metoda

run()

wykonuje zadanie w

tku

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 5

System.out.println("Czas minął!");
timer.cancel();

// Zako

cz w

tek – obiekt

timer

        }
    }
    public static void main(String args[]) {

// Metoda main() klasy głównej

System.out.println("Wybieranie zadania.");
new Przypomnienie(5);

// Konstrukcja obiektu klasy głównej

System.out.println("Zadanie wybrane.");
}
}

Wynik:

Zadanie wybrane.

Czas minął

Drugi napis pojawi si

po 5 sekundach po pierwszym.

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 6

Jednokrotne asynchroniczne wykonanie zadania

o okre

lonej porze

Przykład.

Wykonanie zadania o godzinie 23:01. W tre

ci konstruktora

naszej klasy

Przypomnienie

public Przypomnienie(int sekundy) {

// Pobierz dzisiejsz

dat

Calendar calendar = Calendar.getInstance();

calendar.set(Calendar.HOUR_OF_DAY, 23);

// Ustaw godzin

   calendar.set(Calendar.MINUTE, 1);
   calendar.set(Calendar.SECOND, 0);
   Date time = calendar.getTime();
   timer = new Timer();

// Utwórz w

tek nadzoruj

cy czas

// Wykonaj w

tek zadania o podanej godzinie tego dnia:

timer.schedule( new PrzypomTimerTask(), time);

}

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 7

Zatrzymanie w

tków klasy Timer jest mo

liwe na 4 sposoby:

1. wywołanie metody

cancel()

dla obiektu klasy

Timer

(jak powy

ej);

2. utworzy

tek - „demon” wywołaniem konstruktora:

new Timer(true) ;

program którego jedynymi w

tkami pozostały w

tki demony zako

czy

(w podanych przykładach nie mo

na tak post

, gdy

czekamy

na wykonanie si

zadania zleconego przez obiekt klasy

Timer

);

3. usun

ąć

wszystkie

referencje

do obiektu klasy

Timer

, mo

e to

zako

czy

tek obiektu

Timer

-a.

4. wywołanie metody

System.exit

zako

czy cały program - w tym jego

tki.

Przykład.

Dodanie do klasy

Przypomnienie

dzwonka i wywołanie

metody

System.exit

w celu zako

czenia programu.

public class PrzypomnienieDzwonkiem {

...

public PrzypomnienieDzwonkiem (int sekundy) {

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 8

toolkit = Toolkit.getDefaultToolkit();

// W celu uzyskania dzwonka

timer = new Timer();
timer.schedule(new PrzypomTimerTask(), sekundy*1000);

}

// Klasa dla zadania w

tku

class PrzypomTimerTask extends TimerTask {
public void run() {

            System.out.println(Czas minął!");
            toolkit.beep();
           //timer.cancel();

// Teraz niepotrzebne, gdyŜ wołamy System.exit

System.exit(0);

// Zatrzyma w

tek główny programu (i inne)

}
} ...
}

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 9

Wielokrotne, cykliczne wykonywanie zadania

Przykład.

Wybieramy wykonanie zadania cyklicznie raz na sekund

public class DenerwujacyDzwonek {
    Toolkit toolkit;
    Timer timer;
    public DenerwujacyDzwonek () {
        toolkit = Toolkit.getDefaultToolkit();
        timer = new Timer();
        timer.schedule(new PrzypomTimerTask(),

// początkowe oczekiwanie

1*1000);

// cyklicznie co okres czasu 1 sekundy

    }
    class PrzypomTimerTask extends TimerTask {
        int liczbaDzwonkow = 3;
        public void run() {
          if (liczbaDzwonkow != 0) {
             toolkit.beep();

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 10

             System.out.println("Dzwoni!");
             liczbaDzwonkow--;
          } else {
                toolkit.beep();
                System.out.println("Czas minął!");

timer.cancel();

//Niepotrzebne - wołamy System.exit

System.exit(0);

// Zatrzyma w

tek główny (i inne)

              }
          }
    }
    ...
}

Wynik wykonania

Zadanie wybrane.

Dzwoni!
Dzwoni!      // 1 sekunda po 1-szym "Dzwoni"
Dzwoni!      // 1 sekunda po 2-im "Dzwoni"
Czas minął! // 1 sekunda po 3-im "Dzwoni"

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 11

6.3 Klasa

Thread

Bazowa klasa w

tków to

java.lang.Thread

- wprowadza m.in.

metody

start()

–

rozpoczyna wykonywanie tre

ci w

tku zdefiniowanej w

run()

stop(), stop(Throwable obj);

- (metody niezabezpieczone) zamiast

nich nale

y sprawdza

warunek w

run()

i zako

czy

odpowiednio t

metod

;

sleep(long millis), sleep(long millis, int nanos)

– u

pienie w

tku na

pewien czas;

yield()

–

czasowo zatrzymuje w

tek i ustawia go na ko

cu kolejki;

getPriority(), setPriority(int) –

pobierze i ustawi priorytet w

tku.

1) Metoda

run()

Implementacja

tku

opartego

klasie

Thread

wymaga

zdefiniowania metody

void

run()

- zawera ona zadanie wykonywane

przez w

tek. Klasa

Thread

zawiera definicj

metody

run()

pustym

kodzie.

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 12

Klasy mog

tworzy

metody

run()

dwa sposoby

1. przez dziedziczenie po klasie

Thread

i nadpisanie metody

run()

;

2. przez implementacj

interfejsu

Runnable

- wtedy klasa musi

zawiera

implementacj

metody

run()

Dziedziczenie po klasie

Thread

i nadpisanie

run()

- klasa

Thread

implementuje

Runnable

Przykład

Klasa

ProstyWatek

(implementuje

wątek)

klasa

DemoDwaWatki (wywołuje dwa wątki klasy ProstyWatek):

public class ProstyWatek extends Thread {
public ProstyWatek(String str) {

// Konstruktor klasy

super(str);

// To nada nazwę wątkowi

}
public void run() {

// Metoda run() zawiera zadanie wątku

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

// Wykonuje pętlę 10 razy

System.out.println(i + " " + getName());

// Wyprowadza indeks

// iteracji i nazwę wątku

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 13

try {

sleep((long)(Math.random() * 1000));

// Uśpiony przez

// pewien czas – ale maksimum 1 sekundę.

            } catch (InterruptedException e) {}
        }
        System.out.println("Wykonane! " + getName());

// Wyprowadza

// komunikat, w tym nazwę wątku.

}
}

// Klasa

DemoDwaWatki :

public class DemoDwaWatki {
public static void main (String[] args) {

// Utwórz i uruchom w

tek

new ProstyWatek ("Bahama").start();

// Utwórz i uruchom drugi w

tek

new ProstyWatek ("Bermudy").start(); }
}

Wynik - na przemian wyprowadzane s

wyniki kolejnych w

tków:

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 14

0 Bahama
0 Bermudy
1 Bermudy
1 Bahama
2 Bahama
2 Bermudy
3 Bermudy
...
Wykonane! Bermudy
9 Bahama
Wykonane! Bahama

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 15

2) Implementacja interfejsu

Runnable

przez klas

programisty

Przykład

. Aplet

Zegar

wietla

dzie aktualny czas i od

wie

obraz co sekund

- wykonuj

c odpowiedni w

tek. Klasa

Zegar

implementuje interfejs

Runnable

- w tym metod

run()

import java.awt.Graphics;
import java.util.*;
import java.text.DateFormat;
import java.applet.Applet;
public class Zegar extends Applet implements Runnable {
private Thread watekZegara = null;

// Identyfikator dla obiektu wątku

public void start() {

// Metoda początkowa apletu

if (watekZegara

null) {

// Obiekt klasy Zegar przekaŜe siebie samego do konstruktora Thread –
// w ten sposób przekazana zostanie równieŜ implementacja metody
// run() właściwa dla klasy Zegar do obiektu klasy Thread.

watekZegara = new Thread(this, "Zegar");

//przekazanie do wątku

watekZegara.start();

// Uruchom wątek

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 16

}
}

// Zadanie w

tku w metodzie

run()

public void run() {

Thread mojWatek = Thread.currentThread();
while (watekZegara

mojWatek) {

repaint();

// Metoda apletu wołająca metodę paint()

try {
Thread.sleep(1000);

// Samo-zawieszenie wykonywania wątku

} catch (InterruptedException e){

// Gdy JVM przerwie "nasz sen" zakończymy wykonywanie pętli.

            }
        }
    }

// Nadpisanie metody

paint()

apletu

public void paint(Graphics g) {
Calendar cal = Calendar.getInstance();

// Pobierz dzisiejszą datę

Date date = cal.getTime();

// Pobierz czas, sformatuj go i wyświetl

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 17

        DateFormat dateFormatter = DateFormat.getTimeInstance();
        g.drawString(dateFormatter.format(date), 5, 10);
    }

// Nadpisanie metody

stop()

klasy

Applet

, nie

Thread

public void stop() {

watekZegara = null;

//Zmienia warunek sprawdzany w metodzie run()

}
}

Uwagi

Dzi

ki mechanizmowi w

tków aplet

Zegar

nie blokuje wykonywania

przegl

darki.

li klasa ju

dziedziczy po innej klasie ni

Thread

(jak np.

Zegar

Applet

) to stosujemy 2-gie rozwi

zanie - implementacj

interfejsu

Runnable

W przeciwnym razie - stosujemy rozwi

zanie 1-sze – dziedziczenie

naszej klasy po

Thread

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 18

3) "Cykl

ycia" w

tku

Nowo utworzony

Wykonywany

Zablokowany

Zako

czony

Zako

czenie metody run()

yield

start

Utworzenie w

tku

Np. w metodzie

start()

apletu tworzony jest w

tek o nazwie

watekZegara

public void start() {
if (watekZegara == null) {

watekZegara = new Thread(this, "Zegar");

watekZegara.start();

}

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 19

}

Po utworzeniu w

tek

watekZegara

jest w stanie „

nowo utworzony

”

(„

new Thread

”)

- jest pustym obiektem klasy

Thread

bez zasobów

systemowych. Mo

na go jedynie uruchomi

- metod

start()

(inne

odwołanie spowoduje powstanie wyj

tku

IllegalThreadStateException

Uruchomienie w

tku

public void start() {
if (watekZegara

null) {

watekZegara = new Thread(this, "Zegar");

watekZegara.start();

}
}

Powstaj

zasoby systemowe dla w

tku, wybierany jest w

tek i wołana

jest dla niego metoda

run()

. W

tek b

dzie w stanie "

wykonywania

(

„

running

”

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 20

Zablokowanie (zawieszenie) w

tku

Wykonywanie w

tku zostaje

zawieszone

(stan „

zablokowany

”), gdy:

wywołana zostanie jego metoda

sleep()

;

tek woła metod

wait()

dla oczekiwania na spełnienie warunku;

tek zablokuje si

w oczekiwaniu na operacj

we/wy.

Aby w

tek powrócił do stanu „wykonywania” ze stanu „zablokowania”:

musi upłyn

ąć

okre

lony w wywołaniu

sleep()

czas podany liczb

milisekund;

inny obiekt musi powiadomi

nasz u

piony w

tek o zmianie warunku

wywołuj

notify

lub

notifyAll

;

operacja we/wy, blokuj

ca w

tek, musi si

zako

czy

Ust

pienie czasu procesora innym w

tkom

tek mo

e samoczynnie ust

czas procesora

bez przechodzenia

w stan

zawieszenia

wołaj

c metod

yield()

– przejdzie on na koniec

kolejki w

tkom o jego priorytecie i da szans

na wykonanie si

innym

tkom o tym samym priorytecie co ust

puj

cy w

tek.

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 21

Zako

czenie w

tku

tek ko

czy si

samodzielnie gdy zako

czy si

metoda

run().

W przykładzie z apletem

Zegar

o zako

czeniu p

tli metody

run()

decyduje warunek:

while (watekZegara

mojWatek) {

Gdy przegl

darka opuszcza stron

, na której wykonuje si

aplet wtedy

woła ona metod

stop()

dla apletu. W aplecie

Zegar

oznacza to,

public void stop() {
watekZegara = null;

// Zmieniamy warunek wykonywania się run()

}

Teraz metoda

run()

zako

czy si

-> w

tek jest w stanie „

zako

czony

”.

Metoda klasy

Thread: isAlive()

boolean

isAlive()

Wynik zwracany przez

isAlive

true

- gdy w

tek jest w stanie „wykonywania” lub „zablokowania”;

false

- gdy w

tek jest w stanie

„

nowo utworzony

” lub

„zako

czony”.

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 22

4) Priorytet w

tku - szeregowanie

Priorytet w

tku decyduje o przydzieleniu czasu procesora jednemu z

tków b

cych w stanie „wykonywania” – wybraniu go spo

ród

konkuruj

cych w

tków.

Java

realizuje

deterministyczny

algorytm

szeregowania

(„scheduling”) w oparciu o priorytety:

tek dziedziczy swój priorytet od w

tku który go utworzył.

Metoda

setPriority

umo

liwia zmian

priorytetu - mo

liwe s

warto

MIN_PRIORITY

MAX_PRIORITY

(stałe zdefiniowane w

Thread

Wybierany jest w

tek o najwy

szym priorytecie - z dwóch równych

nast

pny z kolejki FIFO dla danego priorytetu.

tek wykonuje si

w procesorze dopóki nie zajdzie jeden z

przypadków:

Pojawi si

tek o wy

szym priorytecie - w stanie „

wykonywania

”

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 23

tek ust

puje sam (metoda

yield

)

lub ko

czy si

jego metoda

run

W systemach pracuj

cych z podziałem czasu w

tków – gdy jego

kwant czasu ko

czy si

(zale

y to od implementacji klasy

Thread

Wtedy kolejny w

tek b

dzie wybrany do wykonania.

Algorytm wyboru jest

wywłaszczaj

- z chwil

pojawienia si

tku

o wy

szym priorytecie wykonywany w

tek zostaje wywłaszczony.

Java

nie realizuje podziału czasu

, w

tek nie zostanie wywłaszczony

przez inny w

tek o tym samym priorytecie. Jednak implementacja

klasy

Thread

w danym systemie mo

e realizowa

prac

z podziałem

czasu CPU.

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 24

6.4 Synchronizacja pracy w

tków

Do tej pory rozpatrywali

my w

tki, które mog

wykonywa

asynchronicznie

wzgl

dem

siebie.

Jednak

tki

mog

wykorzystywa

wyniki pracy

innych w

tków. W szczególno

ci w

tki

mog

dzieli

te same dane – jednocze

nie odwoływa

do nich

Wtedy ich praca musi by

synchronizowana.

Przykład.
Producent

generuje dane, zapisuje je do obiektu sklad klasy Skladzik a

te s

nast

pnie odczytywane i "konsumowane" przez

konsumenta

Niech producent generuje liczb

pomi

dzy 0 a 9 (wł

cznie),

zapami

tuje j

w obiekcie klasy

Skladzik

i wy

wietla t

liczb

Nast

pnie "zasypia" na losowo dobierany czas (pomi

dzy 0 a 100 ms)

i znowu powtarza cykl generacji danych.

public class Producent extends Thread {
private Skladzik sklad;
private int number;

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 27

Konsument c1 = new Konsument(c, 1);

// Utwórz konsumenta

p1.start();

// Uruchom wątek producenta

c1.start();

// Uruchom wątek konsumenta

}
}

Producent i konsument wymieniaj

dane poprzez

wspólny obiekt

Skladzik

. Ale obie klasy "

Konsument

" i "

Producent

nie synchronizuj

jawnie swoich działa

, nie zapewniaj

tego,

eby konsument

otrzymywał ka

dan

tylko raz

Dlatego w tym przykładzie synchronizacja

musi by

zrealizowana na

"niskim poziomie"

przez metody "

get

" i "

put

" klasy

Składzik

. W innym

przypadku łatwo mo

e powsta

hazard

" w dost

pie do obiektu przez

oba w

tki.

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 28

Sposoby synchronizacji:

zablokowanie innemu w

tkowi dost

pu do obiektu

(sekcja

krytyczna)

– kwalifikator metody

synchronized

powiadamianie si

tków - metody klasy

Thread

wait, notify

notifyAll

Sekcja krytyczna

Przykład (c.d.)

W podanym przykładzie metody

put

get

klasy

Skladzik

tworz

sekcje krytyczne.

public class Skladzik {
    private int contents;
    private boolean available = false;
    public synchronized int get() {
        ...
    }
    public synchronized void put(int value) {
        ...
    }

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 29

}

Z ka

dym obiektem klasy

Skladzik

zwi

zany b

dzie

semafor

. Je

wołana jest metoda synchronizowana to obiekt zostaje zablokowany.

Inny w

tek nie mo

e wykona

metody synchronizowanej

na tym

samym obiekcie do momentu odblokowania obiektu. Uniemo

liwia to

powstanie hazardu w dost

pie do obiektu.

Metody

notifyAll

wait

tki musz

móc powiadamia

e czekaj

na nie dane (

wait

) i

dane zostały dostarczone (

notify, notifyAll

Przykład (c.d.)

Nowe definicje metod

get

put

klasy

Skladzik

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

// Oczekuj na połoŜenie danej przez producenta

} catch (InterruptedException e) {
}

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 30

    }
    available = false;
    notifyAll();

// Powiadom producenta o pobraniu danej

    return contents;
}
public synchronized void put(int value) {
    while (available == true) {
        try {
                wait();

// Oczekuj na pobranie danej przez konsumenta

        } catch (InterruptedException e) {
        }
    }
    contents = value;
    available = true;

notifyAll();

// Powiadom konsumenta o połoŜeniu danej

}

Metod

wait

zwalnia semafor "trzymany" przez "Konsumenta" na

obiekcie "sklad" i oczekuje na powiadomienie od "Producenta".

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 31

Metoda

notifyAll

budzi do

ycia wszystkie w

tki, które oczekuj

dany obiekt (w tym przypadku "sklad"). Konkuruj

one wtedy o

dost

p do obiektu.

Metoda

notify

w klasie

Object

: "budzi" dowolny w

tek spo

ród

oczekuj

cych.

W klasie

Object

zdefiniowano trzy wersje metody

wait

wait()

- oczekuje w niesko

czono

ść

na nadej

cie powiadomienia;

wait (long timeout)

- oczekuje najwy

ej liczb

timeout

milisekund;

wait (long timeout, int nanos)

- oczekuje najwy

ej liczb

timeout

milisekund plus

nanos

nanosekund.

Nale

y unika

"wygłodzenia” i zakleszcze

tków.

"Wygłodzenie" w

tku wyst

pi gdy jeden lub wi

cej w

tków nie

otrzymuje dost

pu do zasobów.

Zakleszczenie to ko

cowe stadium „wygłodzenia” - w

tki czekaj

spełnienie niemo

liwego warunku.

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 32

6.5 Grupowanie w

tków

Klasa

java.lang.ThreadGroup -

umo

liwia zebranie w

tków w jeden

obiekt i jednoczesn

manipulacj

nimi wszystkimi.

Podczas tworzenia w

tku zostaje on przydzielony do jakie

grupy i

musi ju

tam pozosta

Domy

lna grupa w

tków dla aplikacji to jest

main

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 33

Utworzenie nowej grupy w

tków o nazwie

name

•

ThreadGroup(String name)

•

ThreadGroup(ThreadGroup parent, String name)

Np. utworzenie grupy jako elementu domy

lnej grupy w

tków

main

ThreadGroup myThreadGroup = new ThreadGroup(“Moja grupa");

li podczas tworzenia nowego w

tku nie specyfikujemy jego grupy to

zostanie on zaliczony do grupy tego w

tku, który go utworzył.

Trzy konstruktory klasy

Thread

umo

liwiaj

utworzenie i dodanie w

tku

do jawnie podanej grupy:

public Thread(ThreadGroup group, Runnable runnable)
public Thread(ThreadGroup group, String name)
public Thread(ThreadGroup group, Runnable runnable, String name)

Np.

Utworzenie w

tku w nowej grupie:

Thread myThread = new Thread(myThreadGroup, "watek w grupie");

Okre

lenie grupy dla w

tku - metoda

getThreadGroup

, np.:

theGroup = myThread.getThreadGroup();

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 34

Metody klasy

ThreadGroup

Zarz

dzanie kolekcj

activeCount()

- podaje liczb

aktywnych w

tków w grupie;

activeGroupCount()

– podaje liczb

aktywnych grup w

tków w grupie

Klasa implementuje interfejs

Enumerate

, co pozwala m.in. na pobranie

listy aktywnych w

tków tej grupy.

Np.

public class EnumerateTest {
    public void listCurrentThreads() {
        ThreadGroup currentGroup =
                    Thread.currentThread().getThreadGroup();
        int numThreads = currentGroup.activeCount();
        Thread[] listOfThreads = new Thread[numThreads];
        currentGroup.enumerate(listOfThreads);
        for (int i = 0; i < numThreads; i++)
System.out.println("Wątek #" + i + " = " + listOfThreads[i].getName());
    }
}

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 35

Przetwarzanie grupy w

tków

getMaxPriority, setMaxPriority

// Ustawianie priorytetu

getDaemon, setDaemon

getName

getParent, parentOf

toString

Np.

public class MaxPriorityTest {
public static void main(String[] args) {
ThreadGroup groupNORM = new ThreadGroup(

// Utworzenie grupy

"Normalny priorytet grupy");
Thread priorityMAX = new Thread(groupNORM,

// Dodanie wątku

"Wątek o maksymalnym priorytecie");

// Ustaw priorytet wątku na maksymalnie moŜliwy (10)

priorityMAX.setPriority(Thread.MAX_PRIORITY);

// Ustaw maksymalny priorytet grupy na normalny (5)

groupNORM.setMaxPriority(Thread.NORM_PRIORITY);

System.out.println("Maksymalny priorytet grupy = " +

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 36

groupNORM.getMaxPriority());

System.out.println("Priorytet wątku = " + priorityMAX.getPriority());
}
}

Wynik wykonania:

Maksymalny priorytet grupy = 5
Priorytet wątku = 10

Metody operuj

ce na stanie wszystkich w

tkach grupy jednocze

nie

resume() -

wznów

stop() -

zatrzymaj

suspend() -

zawie

Metody te zmieniaj

stan wszystkich w

tków grupy jednocze

nie.

Uwaga: poniewa

wykorzystuj

one metody

resume, stop

suspend

klasy

Thread

nie s

one zabezpieczone przed w

tkami (tzn.

jednoczesnym u

yciem przez wi

cej ni

jeden w

tek).

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 37

Metody kontroli dost

Obie klasy współpracuj

z klas

SecurityManager

Klasy

Thread

ThreadGroup

posiadaj

metod

checkAccess

, która

wywołuje metod

checkAccess

aktualnego „security managera”,

sprawdzaj

prawo dost

pu dla grupy - zgłasza wyj

tek

SecurityException

li nie jest to mo

liwe.

Poni

sze metody klasy

ThreadGroup

wywołuj

metod

checkAccess

zanim wykonaj

swoj

akcj

(regulowany dost

p):

•

ThreadGroup(ThreadGroup parent, String name)

•

setDaemon(boolean isDaemon)

•

setMaxPriority(int maxPriority)

•

stop

•

suspend

•

resume

•

destroy

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 38

Lista metod klasy

Thread

, które wywołuj

checkAccess

zanim wykonaj

swoj

akcj

•

konstruktory specyfikujące grupę wątków;

•

stop

•

suspend

•

resume

•

setPriority(int priority)

•

setName(String name)

•

setDaemon(boolean isDaemon)

6. W

tki.

W. Kasprzak: Programowanie zdarzeniowe

6 - 39

Podsumowanie

Pakiety wspomagaj

ce programowanie wielow

tkowe

java.lang.Thread -

Bazowa klasa dla w

tków w Javie.

java.lang.Runnable

Interfejs

Runnable

zawiera metod

run

wymagan

dla ka

dego w

tku.

java.lang.Object -

Klasa główna

Object

zawiera definicje 3 metod

przeznaczonych do synchronizacji w

tków

wait, notify, notifyAll

java.lang.ThreadGroup -

dy w

tek nale

y do jakie

grupy,

zwykle skupiaj

cej powi

zane ze sob

tki.

java.lang.ThreadDeath

Wymuszenie zako

czenia pracy w

tku jest

liwe dzi

przekazaniu

mu obiektu klasy

ThreadDeath

Elementy j

zyka wspomagaj

ce w

tki

Słowo kluczowe w Javie przeznaczone do synchronizacji w

tków:

synchronized

Elementy

rodowiska wykonania wspomagaj

ce w

tki

rodowisku wykonania Javy wyst

puje szeregowanie w

tków.