Löschen von schedulern im ScheduledThreadPoolExecutor

[== != equals]

Halli hallo,

ich erstelle diesen Executor:

spieltimer = new ScheduledThreadPoolExecutor(3);

Sobald User dran, wird aufgerufen:

bestehendesBeendigungsobjekt = new rundeBeenden(this); // private Objektvariable
spieltimer .schedule(bestehendesBeendigungsobjekt, 10, TimeUnit.SECONDS);

Bewirkt, dass nach 20 Sekunden der nächste Spieler dran ist, die entsprechende Methode dafür wird aus einem Aufruf in run() von dem Objekt bestehendesSpielersetzobjekt aufgerufen. Das klappt auch.
Allerdings weiß ich nicht, wie ich diesen Timer entfernen kann, wenn z.B. ein User innerhalb dieser Zeit setzt und deshalb der Countdown nicht mehr nötig ist.
Habe es schon mit spieltimer.remove(bestehendesBeendigungsobjekt) versucht, klappt aber nicht. Die Aktion wird IMMER nach 10 Sekunden aufgerufen und ich kann es, einmal gesetzt, nicht mehr vorhanden. Bei einem Spieler wirken dann z.B. drei auslaufende Timer gleichzeitig, weil die Spieler davor nur drei Sekunden brauchten.
Wie kann ich also diesen Scheduler wieder entfernen?

Danke für jeden Tipp.

 

[fastjack]

Hi,

probier mal, das Future-Objekt, das aus dem schedule-Aufruf kommt, zu canceln und auf dem ScheduledThreadPoolExecutor die purge-Methode aufzurufen. Das müßte reichen.

Bis dann.

 

[== != equals]

Danke schonmal für die Antwort.

probier mal, das Future-Objekt, das aus dem schedule-Aufruf kommt, zu canceln

Wie? Auf null setzen?

 

[fastjack]

Mit schedule erhältst du eine ScheduledFuture, auf der rufst du cancel() auf. Der ScheduledThreadPoolExecutor ist eine Erweiterung des ThreadPoolExecutor, der die Methode purge() hat. Diese removed alle gecancelten FutureTasks.

 

[== != equals]

Ich vermute, es hat geklappt.
Um sicherzugehen würde ich jetzt noch eine Ausgabe der aktuellen Sheduler erzeugen, ganz primitiv zeilenweise per System.out.println. Gefunden habe ich nur getQueue, da bekomme ich BlockingQueue, aber so richtig ausgeben kann man das damit nicht, oder?

 

[fastjack]

BlockingQueues sind ja im Prinzip Collections. Kommt drauf an, welche Implementierung von BlockingQueue du per getQueue() bekommst, einfach mal checken: getQueue().getClass().getName()

Ich denke mal das ist eine DelayedWorkQueue, in diesem Fall funktioniert iterator() gepaart mit einer passenden Schleife

Sonst vielleicht mal queue.toString() oder Arrays.asList(queue.toArray()) probieren, oder einfach warten, ob der Job noch mal aufgerufen wird oder nicht

 

[== != equals]

toString() hilft ausreichend.

 

[einboubou]

Danke für die Lösung !

Home | myhammers.de

 

[Jango]

Danke für die Lösung !

Home | myhammers.de

An der Seite solltest du aber noch arbeiten...

 

[einboubou]

bei dir "es hat begonnen"
bei mir "es beginn"

Home | myhammers.de

 

[== != equals]

bei dir "es hat begonnen"
bei mir "es beginn"

Hm, stimmt, das ist ein Argument!!!eins