CatchUp - hinter den Kulissen

Das CatchUp-Projekt läuft seit rund vier Monaten und ist mittlerweile bei Version 3.6 angekommen. Mit den letzten Änderungen hat der Podcast Reciever nochmal an Tempo und Stabilität zugelegt, gleichzeitig bin ich zwangsläufig an Erfahrungen reicher geworden.

CatchUp ist stark auf Multithreading ausgelegt, und das bringt einige Herausforderungen mit sich. Wer sich dafür interessiert, kann gerne mal einen Blick unter die Haube werfen und sich ein paar Lösungen anschauen.

Fortsetzung:

RSS-Feeds laden und verarbeiten
Groovy fasziniert mich schon seit Monaten, und den XMLSlurper finde ich so phänomenal, dass ich ihn zum Herzstück von CatchUp gemacht habe.

Wenn man sich den RSS-Feed eines Podcast genauer anschaut, findet man schnell die interessanten Elemente: item, title, pubDate und enclosure.
Hier ein verkürztes Beispiel:

XML:

Das auszulesen ist dank Groovy extrem einfach:

def feedxml=new XmlSlurper().parse(pod.getUrl())

Wobei pod.getURL() die Webadresse des Podcast liefert.
Anschließend läuft eine Schleife für jedes item-Element:

Code:

Hier wird jedes item-Element als "episode" behandelt und Stück für Stück einem eigenen Episode-Objekt zugeordnet. Zu beachten: das @-Zeichen, um das XML-Attribut "url" zu bekommen.

Die komplette Klasse UpdateFeedJob kann man sich hier anschauen.

Warteschlangen und eingeschränkte Parallelität für mehrere Threads

Ein paar Feeds auszulesen geht schnell und macht keine größeren Probleme. Etwas schwieriger ist es, Warteschlangen für Downloads, Prozesse und Kopiervorgänge zu erstellen und dafür zu sorgen, dass sinnvolle Paralellisierung stattfindet. Zwei gleichzeitige Downloads sind o.k., und während der Downloads kann auch MP3Gain im Hintergrund die Lautstärke von MP3-Dateien anpassen. Kopiervorgänge auf den MP3-Player sollten nur nacheinander passieren. Wie geht das?

In den ersten CatchUp-Versionen habe ich noch Quartz eingesetzt, was grundsätzlich funktioniert, aber nicht optimal ist. Quartz ist eigentlich eine Zeitsteuerung für Threads, keine Warteschlangenverwaltung. Inzwischen setze ich ExecutorServices aus dem Paket java.util.concurrent ein. Ein ExecutorService passt genau:


ExecutorService feedUpdater = Executors.newFixedThreadPool(2);

Und schon kann man mit feedUpdater.execute(new UpdateFeedJob(...)) beliebig viele Threads an "feedUpdater" übergeben. Der ExecutorService garantiert, dass maximal zwei davon gleichzeitig laufen und der Rest wartet, bis er an die Reihe kommt.
Details dazu sind in der Klasse TaskController zu finden.

Einfrieren der Benutzeroberfläche verhindern

Noch in Version 3.5 kam es manchmal zu kompletten Blockaden der Swing-Benutzeroberfläche - und die Fehlerquelle konnte ich einfach nicht finden. Deadlocks? Race conditions? Aber wo?
Nach längeren Recherchen fand ich den Hinweis, dass auch Probleme bei Netzwerkverbindungen diesen Effekt haben können und unternahm einen Versuch mit Spin. Und siehe da: seitdem kein einziger "Freeze" mehr. Verblüffend einfach und effekiv! Vor dem Einsatz unbedingt die Beschreibung lesen.