Konkurentno i distribuirano programiranje u Javi

nobody@mycity.rs (Mila_90) — Sun, 09 Dec 2012 21:33:48 +0100

Osnove konkurentnog i distribuiranog programiranja u Javi

Pored nezaobilazne preporu�ene literature iz konkurentnog i distribuiranog programiranja:

1. The Little Book of Semaphores, Allen B. Downey
2. Taming Java Threads, Allen Holub
3. Foundation of Multithreaded, Parallel and Distributed Programming, Gregory Andrews, Addison Wesley,2000
4. Konkurentno i distribuirano programiranje, Zaharije Radivojevi�, Igor Ikodinovi�, Zoran Jovanovi�, Akademska misao, 2008

korisno je pogledati slede�e video snimke sa prakti�nih ve�bi dr Zaharija Radivojevi�a, na Elektrotehni�kom fakultetu Univerziteta u Beogradu.

Obra�ene su slede�e oblasti:

1. Sinhronizacija niti
2. Distribuirano programiranje pomo�u soketa
3. Udaljeni pozivi metoda (RMI)

Sa prvog snimka se mo�e nau�iti slede�e:

1. Osnove rada u razvojnom okru�enju Eclipse
Download

2. Koncept po�tanskog sandu�eta (Message Box)

3. Izrada jednostavnog GUI-ja (pomo�u Java Swing)
- Komponente JButton, JTextArea, JWindow
- Koncept Event-a (doga�aja) i Action listener-a.

4. Ponavljanje osnova programskog jezika Java
- paketi
- metode
- prosle�ivanje argumenata
- definicija promenljivih
- klase
- interfejsi
- konstante
- gotove klase za rad sa listom i drugim strukturama podataka
- izuzeci
- doga�aji
- generi�ke klase

5. Koncept bounded buffer-a (kru�nog bafera)

6. Sinhronizacija niti i rada po�tanskog sandu�eta pomo�u interfejsa Lock i njegove implementacije ReentrantLock

Na drugom snimku se mo�e videti:

1. Debagovanje u razvojnom okru�enju Eclipse
2. Demonstracija i ispravljanje naj�e��ih gre�aka u sinhronizaciji i GUI-ju
3. Implementacija po�tanskog sandu�eta koriste�i klju�nu re� synchronized
4. Implementacija po�tanskog sandu�eta koriste�i nizove i semafore u Javi (u java.util.concurrent paketu)

Tre�i snimak:

1. Upore�ivanje performansi prethodnih implementacija po�tanskog sandu�eta
2. Tokovi podataka u programskom jeziku Java
3. Implementacija po�tanskog sandu�etu u distribuiranom okru�enju pomo�u soketa

�etvrti snimak:

1. Implementacija po�tanskog sandu�eta pomo�u udaljenih poziva metoda (RMI u Javi)

Svaka ispravka, bilo stru�na, bilo u vezi izgleda teme je dobrodo�la

----------- Dopuna: 09 Dec 2012 21:34 ---------

Sinhronizacija niti pomo�u klju�ne re�i synchronized, metoda wait i notify

Deo koda ili metod se mogu deklarisati kao kriti�na sekcija kori��enjem klju�ne re�i synchronized.

1. Deo koda
synchronized (someObject) { ... }
U ovom slu�aju, deo koda je kriti�na sekcija, a objekat odgovara uslovnom kriti�nom regionu.

2. Metod

public class SomeClass {


public synchronized void f(...) {


...


}


}

Deo koda je kriti�na sekcija, a objekat odgovara monitorima sa signal and continue disciplinom.

3. Naredba wait()

Naredba wait prekida izvr�avanje niti i stavlja je u stanje �ekanja. Privremeno se skida zabrana drugim nitima koje pristupaju monitoru.

wait(tmilisec) �eka se najvi�e tmilisec milisekundi dok neka druga nit ne pozove notify() ili notifyAll() za taj objekat.

wait(tmilisec,tnanosec) �eka se najvi�e tmilisec milisekundi i tnanosec nanosekundi dok neka druga nit ne pozove notify() ili notifyAll() za taj objekat.

wait() �eka neograni�eno dok neka druga nit ne pozove notify() ili notifyAll() za taj objekat.

4.Naredba notify()

Naredba notifyАll() �alje notifikaciju svim nitima koje �ekaju da pristupe ciljnom objektu da to mogu u�initi.
Naredba notify() radi isto �to i notifyАll(), ali notifikuje samo jednu nit.

Demonstrira�emo upotrebu klju�ne re�i synchronized i pomenutih metoda u sinhronizaciji niti na primeru po�tanskog sandu�eta iz uvodnog dela �lanka.

public class ArrayMessageBox<T> implements MessageBox<T> {


   Object[] buffer;


   int first, last, size;





   public ArrayMessageBox(int num) {


      buffer = new Object[num];


      first = 0;


      last = 0;


      size = 0;


   }





   public synchronized Message<T> get(long ttw, Status status) { //�itav metod je synchronized


      while (size == 0) {


         try {


            wait(); //�eka se da ne�to ima u baferu.


         } catch (InterruptedException e) {


            e.printStackTrace();


         }


      }


      Message<T> result = (Message<T>) buffer[first];


      first = (first + 1) % buffer.length;


      size--;


      notifyAll();// Sve niti se obave�tavaju da je ne�to uzeto iz bafera - to �e probuditi proizvo�a�e koji �ekaju slobodno mesto u baferu.


      return result;


   }





   public synchronized void send(Message<T> m, Priority p, long ttl) { //�itav metod je synchronized





      while (size == buffer.length) {


         try {


            wait(); //�eka se da ima barem jedno slobodno mesto u baferu. 


         } catch (InterruptedException e) {


            e.printStackTrace();


         }


      }


      buffer[last] = m;


      last = (last + 1) % buffer.length;


      size++;


      notifyAll(); //Sve niti se obave�tavaju da je ne�to uba�eno u bafer - to �e probuditi one potro�a�e koji �ekaju da uzmu ne�to iz bafera.


   }





}

Java Developers Almanac

nobody@mycity.rs (snoop) — Mon, 17 Apr 2006 01:45:24 +0100

Uplivah ja i u Javine vode .

[Link mogu videti samo ulogovani korisnici]

MyCity :: Java

Konkurentno i distribuirano programiranje u Javi

Java Developers Almanac