Dotaz: Java Timer - přerušení a znovuspuštění tasku

[dandyg]

Můj problém:

Mám aplikaci ve Swingu, kde je několik samostatných panelů, do kterých periodicky dodávám data. Data dodávám pomocí observable-observer, což skvěle funguje. Zatím periodické provádění zajišťuji pomocí java.util.Timer a java.util.TimerTask.

V konstruktoru "aplikační" třídy odděděné od TimerTask vytvářím novou instanci Timer a následně provedu schedule(this,0,delay); neboli spouštím periodické opakování metody run z té samé třídy. To také funguje jak má. Nyní bych ale chtěl periodické provádění přerušit a později opět spustit.

Pokud ale provedu timer.cancel(); a později se znovu pokusím úlohu naplánovat, logicky a zcela očekávaně to skončí IllegalStateException, přesně podle javadoc. Zkusil jsem tedy před opětovným naplánováním vytvořit novou instanci Timer a naplánovat již nad novým timerem, ale problém stále trvá.

Nemá někdo s tímto zkušenosti. Popřípadě ocením i jiné možnosti opakování úlohy s možným přerušením a znovuspuštěním.

---

---

Odpovědi

[moira]

Neměl by se spíše cancellnout TimerTask?

[msaft]

od boku: ScheduledThreadPoolExecutor(1) a setCorePoolSize(0) pro preruseni?

[dandyg]

Na to zastavení a opětovné spuštění můžeš zkusit použít místo cancel nějakou proměnnou (atomickou) nebo nějaký zámek. Např.

         try {

            final Lock locker = new ReentrantLock();
            final ScheduledExecutorService scheduler =
                    Executors.newScheduledThreadPool(1);
            final Runnable beeper = new Runnable() {

                public void run() {
                    locker.lock();
                    System.out.println("some job");
                    locker.unlock();
                }
            };

            final ScheduledFuture jobHandler =
                    scheduler.scheduleWithFixedDelay(beeper, 1, 5, TimeUnit.SECONDS);
             
            TimeUnit.SECONDS.sleep(6);
            System.out.println("zastavujem");
            locker.lock();
            TimeUnit.SECONDS.sleep(12);
            System.out.println("poustime");
            locker.unlock();
            TimeUnit.SECONDS.sleep(12);
            System.out.println("koncime");
            jobHandler.cancel(false);
            scheduler.shutdown();

        } catch (InterruptedException ex) {
            Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
        }

[dandyg]

To je přesně to, co jsem potřeboval. Díky moc!