Vlákna v Javě

Z MiS
(Rozdíly mezi verzemi)
Přejít na: navigace, hledání
(Přidána komunikace mezi vlákny, upravena struktura...)
(Oprava kódu časovače, doplněn anonymní listener.)
 
(Nejsou zobrazeny 2 mezilehlé verze od 1 uživatele.)
Řádka 1: Řádka 1:
[[Category:VSE]][[Category:Informatika]][[Category:Java]]
+
[[Category:VSE]][[Category:Informatika]][[Category:Java]][[Category:Stránky s obrázky]][[Category:Programování]]
  
 
== Výhody a nevýhody práce s vlákny ==
 
== Výhody a nevýhody práce s vlákny ==
Řádka 26: Řádka 26:
 
  run()
 
  run()
 
*Popisuje, co má vlákno vykonávat.
 
*Popisuje, co má vlákno vykonávat.
<div class="Varovani>Tuto metodu nikdy nevoláme přímo, spustí ji třída Thread sama při volání metody <code>start()</code>.</div>
+
<div class="Varovani">Metodu <code>run()</code> nikdy nevoláme přímo, spustí ji třída <tt>Thread</tt> sama při volání metody <code>start()</code>.</div>
 
  start()
 
  start()
 
* Vytvoří vlákno a spustí v něm kód metody <code>run()</code>.
 
* Vytvoří vlákno a spustí v něm kód metody <code>run()</code>.
Řádka 98: Řádka 98:
 
* Přidáme posluchače (''listenery'', implementují rozhraní <tt>ActionListener</tt>).
 
* Přidáme posluchače (''listenery'', implementují rozhraní <tt>ActionListener</tt>).
 
* <tt>Timer</tt> ve stanovených intervalech posílám všem posluchačům zprávu <tt>actionPerformed</tt>.
 
* <tt>Timer</tt> ve stanovených intervalech posílám všem posluchačům zprávu <tt>actionPerformed</tt>.
 +
 +
; Vytvoření časovače
 +
Timer ''nazevCasovace'' = new Timer(''delkaIntervaluMs'', ''listener'');
 +
 +
; Spuštění časovače
 +
''nazevCasovace''.start();
 +
 +
; Příklady kódu
 
<div class="Priklad">
 
<div class="Priklad">
; Příprava posluchače
+
* Příprava posluchače
  class Posluchac implements ActionListener() {
+
  class Posluchac implements ActionListener {
 
     public void actionPerformed(ActionEvent e) {
 
     public void actionPerformed(ActionEvent e) {
 
       ... ''co se má pravidelně vykonat'' ...
 
       ... ''co se má pravidelně vykonat'' ...
 
     }
 
     }
 
  }
 
  }
; Spuštění časování
+
* Spuštění časování
  Timer t = new Timer(new Posluchac(), 1000);
+
  Timer t = new Timer(1000, new Posluchac());
 +
t.start();
 +
</div>
 +
<div class="Priklad">
 +
* Můžeme samozřejmě také použít anonymní listener (od Javy 8 i&nbsp;s&nbsp;lambda notací)
 +
Timer t = new Timer(1000, (ActionEvent e) -&gt; { System.out.println("Tik!"); } );
 
  t.start();
 
  t.start();
 
</div>
 
</div>
 +
  
  
Řádka 117: Řádka 131:
 
; Příklad &mdash; Pravidelný výpis stavu výpočtu
 
; Příklad &mdash; Pravidelný výpis stavu výpočtu
 
[[Image:komunikace-vlaken.png]]
 
[[Image:komunikace-vlaken.png]]
 +
  
  
 
== Další informace ==
 
== Další informace ==
 
* [http://docs.oracle.com/javase/tutorial/essential/concurrency/threads.html Docs.Oracle.com > JavaSE > Tutorial > Essential > Concurrency > Threads]
 
* [http://docs.oracle.com/javase/tutorial/essential/concurrency/threads.html Docs.Oracle.com > JavaSE > Tutorial > Essential > Concurrency > Threads]

Aktuální verze z 11. 6. 2018, 08:51


Obsah

Výhody a nevýhody práce s vlákny

Výhody
Problémy
Kdy má smysl?


Implementace v Javě


Metody třídy Thread
run()
Metodu run() nikdy nevoláme přímo, spustí ji třída Thread sama při volání metody start().
start()
Thread.sleep(int time)
stop() — nedoporučuje se!!!
Metoda stop() je zastaralá (depricated) a neměla by se používat! Vlákno by mělo skončit vždy samo ve vhodný okamžik na základě ukončení metody run().


Spuštění vlastního vlákna

Postup
  1. Implementujeme v naší třídě (třeba Vlakno) rozhraní Runnable.
    • Musíme doplnit metodu public void run().
    • V metodě run() napíšeme kód, který má vlákno provádět.
  2. Vytvoříme instanci třídy Vlakno.
  3. Vytvoříme instanci třídy Thread.
    • V konstruktoru předáme instanci třídy Vlakno.
  4. Zavoláme metodu start() třídy Thread.
Popis chování vlákna
class Vlakno implements Runnable {
   ...
   public void run() {
      ... co se má dělat ve vlákně ...
   }
   ...
}
Spuštění vlákna
Vlakno v = new Vlakno();
Thread t = new Thread(v);


Z více vláken nelze používat


Modifikátor synchronized

synchronized {...}


Synchronizace kolekce

List<Prvek> data = Collections.synchronizedList(new ArrayList<Prvek>()); 
synchronized(data) {
   Iterator i = data.iterator(); // Must be in synchronized block
   while (i.hasNext())
      foo(i.next());
}


Časování — třída Timer

Vytvoření časovače
Timer nazevCasovace = new Timer(delkaIntervaluMs, listener);
Spuštění časovače
nazevCasovace.start();
Příklady kódu
  • Příprava posluchače
class Posluchac implements ActionListener {
   public void actionPerformed(ActionEvent e) {
      ... co se má pravidelně vykonat ...
   }
}
  • Spuštění časování
Timer t = new Timer(1000, new Posluchac());
t.start();
  • Můžeme samozřejmě také použít anonymní listener (od Javy 8 i s lambda notací)
Timer t = new Timer(1000, (ActionEvent e) -> { System.out.println("Tik!"); } );
t.start();


Komunikace mezi vlákny

Příklad — Pravidelný výpis stavu výpočtu

Komunikace-vlaken.png


Další informace

Osobní nástroje
Jmenné prostory
Varianty
Akce
Výuka
Navigace
Nástroje