Sönke Eilers

Real - Time Java Seminar

Asynchrone Ereignisse und Asynchroner Kontrolltransfer in Real - Time Java

Sönke Eilers

Überblick

• Asynchrone Ereignisse ( Async Events )• Behandlungsprozeduren für Asynchrone

Ereignisse ( Async Event Handler )• Asynchroner Kontrolltransfer

Asynchrone Ereignisse - Problematik

• In Realzeit – Systemen treten häufig Ereignisse auf

• Ereignisse treten zu nicht vorhersehbaren Zeitpunkten und in unbekannten Frequenzen auf (asynchron)

• Innerhalb eines Prozesses oder außerhalb (anderer Prozess, OS) eines Prozesses

Asynchrone Ereignisse - Anwendungsgebiete

• Ein Prozess soll über einen Fehler in einem anderen Prozess informiert werden

• Innerhalb einer Software soll möglichst schnell und zu nicht vorhersehbaren Zeitpunkten der Betriebsmodus geändert werden ( z.B. ein sicheres Herunterfahren eines Systems im Fehlerfall )

• Um Berechnungen planbar zu machen• Der Benutzer möchte den Prozess unterbrechen

Asynchrone Ereignisse

• Behandlung von Ereignissen durch Threads ist zu langsam, weil dem Thread Resourcen zugewiesen werden müssen

• Es sind Mechanismen nötig, um schnell auf asynchrone Ereignisse zu reagieren

• Handler sind in RTSJ ebenso wie Threads planbar, jedoch sind mehrere Handler auf einen Thread angesetzt

Asynchrone Ereignisse - Ebenen

A syn ch ro n es E re ign is - E b en e

B eh an d lu n gsp ro zed u ren - E b en e

S chn ittste llen - E bene

Asynchrone Ereignisse – Schnittstellen-Ebene

• Die Schnittstellen – Ebene stellt die Verbindung zwischen der Umgebung und der JVM her

• Die Umgebung kann sowohl ein Betriebssystem als auch Hardware sein

• Die JVM wird mittels der Schnittstellen – Ebene über externe Ereignisse ( Happenings ) informiert

Asynchrone Ereignisse – Asynchrones Ereignis Ebene

• Objekte der Klasse AsyncEvent werden mit Hilfe der bindTo Methode mit einem externen Ereignis verbunden:AsyncEvent aEvent = new AsyncEvent();aEvent.bindTo(“2“); // 2 ist SIGINT

• Der Schnittstellen – Ebene wird so mitgeteilt, dass dieses externe Ereignis an das Objekt aEvent weitergeleitet wird

• Das AsyncEvent startet die mit dem Ereignis assoziierten Behandlungsprozeduren

Asynchrone Ereignisse – Behandlungsprozeduren-Ebene

• Behandlungsprozeduren sind Objekte der Klasse AsyncEventHandler

• AsyncEvent Objekte werden mit den Methoden addHandler und setHandler mit Behandlungsprozeduren verbunden

• removeHandler entfernt den jeweiligen Handler


A syn ch ro n es E re ign is - E b en e

B eh an d lu n gsp ro zed u ren - E b en e

S chn ittste llen - E bene

ex tern es E re ign is

b in d T o ()

ad d H an d ler()

h an d leA syn cE ven t()

Asynchrone Ereignisse – Klasse AsyncEvent

A s y n cEv e n t

v o id ad d H an d ler( A s y n cE v en t H an d ler h an d ler)v o id b in d T o ( jav a.lan g.St rin g h ap p en in g)R eleas eP aram et ers creat eR eleas eP aram et ers ()v o id fire()b o o lean h an d led B y ( A s y n cE v en t H an d ler h an d ler)v o id rem o v eH an d ler( A s y n cE v en t H an d ler h an d ler)v o id s et H an d ler( A s y n cE v en t H an d ler h an d ler)v o id u n b in d T o ( jav a.lan g.St rin g h ap p en in g)


1. AsyncEvent event = new AsyncEvent();2. AsyncEventHandler handler = new

AsyncEventHandler()3. // weitere Anweisungen zum Instanzieren von

handler4. // … 5. event.bindTo(“2“);6. event.addHandler( handler );7. event.fire();8. If ( event.handledBy( handler )9. {10. event.removeHandler( handler );11. }12. event.unbindTo(„2“);

Asynchrone Ereignisse - Assoziation

• Ein Ereignis kann durch mehrere Behandlungsprozeduren behandelt werden

• Mehrere Ereignisse können von der gleichen Behandlungsprozedur behandelt werden – Handler weiß jedoch nicht, welches Ereignis ihn aufgerufen hat

A sy n cE v en t A s yn cE v en tHan d ler1 . . .* 1 . . .*

Asynchrone Ereignisse – Behandlungsprozeduren-Ebene

• Wenn ein Ereignis auftritt, werden alle mit dem Ereignis verbundenen Behandlungsprozeduren gestartet

• Im AEH wird durch das Ereignis die run Methode ausgeführt, die für jedes Auftreten des Ereignis die Methode handleAsyncEvent aufruft

Asynchrone Ereignisse – Klasse AsyncEventHandler

A s y n cEv e n tH a n dle r

p ro t ect ed in t get A n d C learP en d in gF ireC o u n t ()p ro t ect ed in t get A n d D ecrem en t P en d in gF ireC o u n t ()p ro t ect ed in t get A n d In crem en t P en d in gF ireC o u n t ()v o id h an d leA s y n cEv en t ()v o id ru n ()


AsyncEventHandler handler = new AsyncEventHandler(){

public void handleAsyncEvent(){

System.out.println(“Im Handler!“);

}

};




int pending;

do{


} while ( (pending = getAndDecrementPendingFireCount()) > 0 );

}

};




int fireCount = getAndClearPendingFireCount();


}

};

Das Ereignis ist mehrmals aufgetreten, soll aber nur einmal behandelt werden

Asynchrone Ereignisse - Klassendiagramm

• AsyncEventHandler implementiert die beiden Interfaces java.lang.Runnable und java.lang.Schedulable

• BoundAsyncEventHandler erbt von AsyncEventHandler

• Objekte der Klasse AsyncEventHandler sind planbar

< < I n te rfa ce > >R u n n a ble

< < I n te rfa ce > >S ch e du la ble


B ou n dAsyn cEve n tH an dl e r

O bje ct

Threads vs. AEHs

Threads warten und schlafen

AEHs sind blockiert, oder werden ausgeführt

Threads können lange laufen

AEHs sollen meist nur wenig Code ausführen und beenden

Threads müssen unter Umständen auf Resourcen warten

AEHs sollen so bald wie möglich ausgeführt werden

Asynchrone Ereignisse - Implementierung von Asynchronous Event Handler

• Die Referenz – Implementierung von RTSJ erzeugt für jeden AEH einen Thread, wenn ein Ereignis aufgetreten ist

• Schlechte Leistung der Implementierung• Verbesserung: für jeden AEH wird ein Thread

erzeugt

Asynchrone Ereignisse – Bound Asynchronous Event Handler

• Die Klasse BoundAsyncEventHandler erbt von der Klasse AsyncEventHandler

• Ein BoundAsyncEventHandler ist dauernd an einen eigenen Thread gebunden und hat ein besseres Zeitverhalten als ein AEH


B o u n dA s y n cEv e n tH a n dle r

Asynchrone Ereignisse – Programmieren mit AEHs

• Verwendung der AEHs zu andern Zwecken als auf externe Ereignisse zu reagieren:– Jeglicher Code, der die fire Methode eines

Ereignisses aufrufen kann– Zeitliche Ereignisse ( Timer )– Fehler

Asynchrone Ereignisse – Timer

• Die Timer Objekte werden mit einem Handler verbunden

• Der OneShotTimer führt seinen Handler zu einem bestimmten Zeitpunkt aus

• Der PeriodicTimer führt seinen Handler periodisch aus

O bje ct

A s y n cEv e n t

Pe rio dicTim e rO n e S h o tTim e r

T im er{ a bs tra ct }

Asynchrone Ereignisse - OneShotTimer

OneShotTimer timer = new OneShotTimer(

new RelativeTime( 10000, 0 ),

// 10 Sekunden

handler);

timer.start();

10 Sekunden nach Start des Timers wird der für timer eingetragene Handler ausgeführt.

Asynchrone Ereignisse - PeriodicTimer

PeriodicTimer timer = new PeriodicTimer( null, // wird sofort gestartet new RelativeTime(2000, 0), // alle 2 Sek. handler);timer.start(); … timer.disable(); … timer.enable();

//…timer.stop();

Der PeriodicTimer löst nach dem Aufruf seiner start Methode alle 2 Sekunden seinen Handler aus.

Asynchrone Ereignisse – Fehlerbehandlung mit AEs

• Im Fehlerfall kann die fire Methode eines Asynchronen Ereignisses dazu genutzt werden, dass– die Fehlerbehandlung asynchron zu dem Code

stattfindet, der den Fehler ausgelöst hat– verschiedene Threads einen Handler für ein Ereignis

registrieren können

Asynchrone Ereignisse – weitere Nutzung

• Anstelle eines RealTime - Threads• Als ein allgemeiner Mechanismus für

Mitteilungen innerhalb eines Programms (um AWT events zu ersetzen )

Asynchroner Kontrolltransfer

• Man unterscheidet bei der Behandlung von asynchronen Meldungen zwischen– dem wiederaufnehmenden Modell ( Event Handling )– dem terminierenden Modell (ATC)

Asynchroner Kontrolltransfer – wiederaufnehmendes Modell (AEH)

• Das wiederaufnehmende Modell wird auch Ereignisbehandlung genannt

• Ein Prozess wird durch ein Ereignis unterbrochen, behandelt dieses und fährt an der Stelle weiter, an der es unterbrochen wurde

• Die Behandlung kann auch nebenläufig stattfinden

Asynchroner Kontrolltransfer - AEH

T h r ead T h r ead

Han d ler Han d ler

E r e ig n is

Beh an d lu n gab g es c h lo s s en

Asynchroner Kontrolltransfer – terminierendes Modell (ATC)

• Asynchroner Kontrolltransfer:• Jeder Prozess hat einen bestimmten Bereich,

innerhalb dessen er durch eine asynchrone Nachricht unterbrochen werden kann

• Dies kann den Thread beenden oder weitere Aktionen im Thread auslösen


• In früheren Implementierungen von Threads in Java gab es die Methoden resume, suspend und stop

• Diese sind inzwischen veraltet ( deprecated )• Es werden heute nur noch die Methoden interrupt und destroy als Mechanismen für ATC in Java genutzt


• Der asynchrone Kontrolltransfer ist in die Ausnahmebehandlung integriert worden

• ATC wird in RTSJ durch das werfen einer AIE Ausnahme erreicht

Th ro wa ble

Ex ce pt io n

O bje ct

Tim e d

I n te rru pte dEx ce pt io n

A s y n ch ro n o u s lyI n te rru pte dEx ce pt io n

< < I n te rfa ce > >S e ria liza ble


• Der Bereich, in dem der Thread unterbrochen werden darf, muss festgelegt werden:

void tuWas() throws AsynchronouslyInterruptedException {}

• Methoden die keine AIE werfen sind daher nicht von Interrupts betroffen

• Somit ist auch älterer, ererbter Code der nichts von RTSJ weiß sicher vor Überraschungen

Asynchroner Kontrolltransfer – ATC in RTSJ

• Es gibt drei Mechanismen in RTSJ, um eine AIE auszulösen:– Die interrupt Methode auf einen RealtimeThread aufrufen

– Die fire Methode auf einer AIE aufrufen– Ein Timed Objekt wirft eine AIE auf eine run

Methode


• Erzeugt man in einem Thread mit Hilfe von rt.interrupt() eine Ausnahme in dem RealtimeThread rt, so spricht man von einer generic AIE, die geworfen wird

• Dieser Mechanismus ist dazu gedacht, den jeweiligen Thread zu beenden, die AIE kann aber auch innerhalb einer catch Anweisung behandelt werden ( hierfür ist AIE.fire() besser geeignet)

• Die Ausnahme ist nicht mit der doInterruptable Methode verbunden


• Wenn man einen Thread mit rt.interrupt() unterbricht, ist die Reaktion abhängig von dem Zustand in dem sich der Thread befindet

• Ist der Thread in einer Methode oder an einer Stelle im Thread, die keine AIEs behandeln kann, wird abgewartet, bis das Programm eine Methode erreicht in der eine AIE geworfen werden kann

public void nichtUnterbrechbar { … }

… // nicht unterbrechbar im RT-Thread

public void unterbrechbar throws AIE {…}


• Innerhalb des try Blocks wird die Ausführung unterbrochen und es geht beim catch weiter

• Wird keine AIE gefangen, wird die AIE in der aufrufenden Methode geworfen

public void unterbrechbar() throws AIE{

try{

…

} catch (AIE aie){}

}


• Wird die AIE außerhalb des try Blocks geworfen, wird die Methode terminiert und die wird AIE in der aufrufenden Methode geworfen


… // sollte die AIE hier geworfen werden

try{

…

} catch (AIE aie){}

}


• Falls der Thread durch ein wait, sleep oder join blockiert ist, wird der Thread neu geplant und die AIE wird geworfen


Thread.sleep( 2000 );

}


• Falls der Thread in einer nicht zu unterbrechenden Methode blockiert ist, wird der Thread neu geplant und die AIE als abwartend markiert

public void nichtUnterbrechbar(){

Thread.sleep( 2000 );

}


• Die fire Methode wird auf einem AIE Objekt aufgerufen

• Zusammen mit der doInterruptable Methode des AIE Objekts kann man so einen Asynchronen Interrupt an eine bestimmte Methode eines RT-Threads schicken

• Die doInterruptible Methode eines AIE Objekts hat als Argument ein Objekt einer Klasse, die das Interruptible interface implementiert


A s y n ch ro n o u s ly I n te rru pte dEx ce pt io n

d o In t erru p t ib le( In t erru p t ib le lo gic)

< < in te rfa ce > >I n te rru pt ible

in t erru p t A ct io n ( A IE excep t io n )ru n ( A IE excep t io n )

P ar am eterf ü rd o I n ter r u p tib le

• In der run Methode steht der Code der ausgeführt werden soll

• In der interruptAction Methode der Code, der im Fall eines Interrupts ausgeführt werden soll


rt.this.aie = new AIE();

rt.this.aie.doInterruptible(

new Interruptible(){

public void interruptAction( AIE aie ){

// wird bei Interrupt ausgeführt

}

public void run( AIE aie) throws AIE{

// wird ansonsten ausgeführt

}

}); // Ende von doInterruptible


Tim e d

d o In t erru p t ib le( In t erru p t ib le lo gic)res et T im e( H igh R es o lu t io n T im e t im e)

• Ein Timed Objekt wirft zu einem gegebenen Zeitpunkt eine AIE in der run Methode seiner doInterruptible Methode

Timed timed = new Timed( new RelativeTime(1000,0));

Timed.doInterruptible( new Interruptible() {…});

Vorführung

Documents

Sönke Eilers