Threads mit Argument?

[nabla]

Hi,

ich moechte eine XML Datei einlesen und Objekt fuer Objekt in der Datei parallel (am besten Threads=Anzahl CPUs) bearbeiten. Am Ende der Berechnung in einem Thread wird dann in einem Feld, auf dass alle Threads zugreifen sollen, der Wert um 1 erhoeht (diesen Schreibzugriff, denke ich, muss man locken). Dieses Feld ist in der Klasse, in der auch der berechnende Code ist.

Bis jetzt laeuft das so, dass die XML-Datei geparst wird, und immer wenn ein komplettes Objekt eingelesen wird, wird das Objekt an eine Prozedur weitergegeben. Nun koennte ich diese Prozedur auch run nennen, nur bekommt sie halt kein Argument. Was kann man da machen? Ist die einzige Moeglichkeit, dass man in die Klasse ein temporaeres Objekt einbaut, dass dann immer von run gelesen wird? Aber bekommt man das sicher hin?

btw.: Muss man bei Schleifenvariablen etc. auch aufpassen, dass die Threads sich da nicht ueberschneiden (soll ja gleicher code, nur mit anderen Daten sein)? Wie macht man das?

Ich hoffe, ich konnte mich klar ausdruecken.

Danke

 

[hiti]

Hallo nabla,

Um in einem Thread arbeiten an Objekten zu verrichten kannst du natürlich das benötigte Objekt per Konstruktor ans Thread-Objekt geben. In der run des Threads bearbeitest du dann dieses übergebene Objekt, oder du rufst nur noch eine Methode des Objekts auf, die die eigentliche Arbeit macht. Wenn du bzgl. Sicherheit gleichzeitige Zugriffe auf Objekte meinst, musst du ein paar Sachen beachten. Z.B. darf ein und das gleicht Objekt nur in einen Thread gegeben werden. Wenn das nicht sichergestellt werden kann muss das Objekt während der Bearbeitung gelockt (synchronisiert) werden.

Zur letzten Frage: Hier musst du unterscheiden, ob es Instanz-Variablen oder Klassen-Variablen (static) sind. In Schleifen verwendet man in der Regel lokale Instanz-Variablen. Diese sind dann nur für dieses Objekt und nur an dieser Stelle 'sichtbar' und gültig. Ein weiteres Objekt hat darauf keinen Einfluss.

Gruss, hiti

 

[nabla]

Um in einem Thread arbeiten an Objekten zu verrichten kannst du natürlich das benötigte Objekt per Konstruktor ans Thread-Objekt geben. In der run des Threads bearbeitest du dann dieses übergebene Objekt, oder du rufst nur noch eine Methode des Objekts auf, die die eigentliche Arbeit macht. Wenn du bzgl. Sicherheit gleichzeitige Zugriffe auf Objekte meinst, musst du ein paar Sachen beachten. Z.B. darf ein und das gleicht Objekt nur in einen Thread gegeben werden. Wenn das nicht sichergestellt werden kann muss das Objekt während der Bearbeitung gelockt (synchronisiert) werden.

Ok. In meinem Fall habe ich das Gefuehl, dass das etwas kuenstlich wirkt, da ich nun die rechnende Einheit (der Code, der in run muss), getrennt von der Klasse, in der die Ergebnisfelder und anderen benoetigten Groessen sind, halten muss. Letzteres waere fuer alle Datenteile das gleiche. Wird aber vermutlich am besten so sein. Das heisst, ich erzeuge eine Klasse, in der das allgemeine Datenobjekt und der Teil der XML Datei sind.

Zur letzten Frage: Hier musst du unterscheiden, ob es Instanz-Variablen oder Klassen-Variablen (static) sind. In Schleifen verwendet man in der Regel lokale Instanz-Variablen. Diese sind dann nur für dieses Objekt und nur an dieser Stelle 'sichtbar' und gültig. Ein weiteres Objekt hat darauf keinen Einfluss.

Danke, macht Sinn.


Eine Frage noch: kann man dafuer sorgen, dass zum Beispiel nur gleichzeitig 4 threads gleichzeitig laufen? Ein Grund, warum ich die XML Datei zerlegen muss, ist, dass sie viel zu gross fuer den Speicher ist... Klappt das mit newFixedThreadPool(4) und packt alle threads dort rein und er arbeitet immer 4 gleichzeitig ab? Problem ist, dass das nicht genau das ist, was ich brauche, weil ich mit dem "Hauptthread", also mit dem Einlesen, warten muss, wenn zu viele threads noch nicht bearbeitet sind.

Danke!