Java Thread

[redbomber]

Hi zusammen,

ich bin gerade dabei in meinem Programm einen Thread zu starten, dafür habe ich ein eigenes Thread Object implementiert:

Die run() Methode von meinem Thread sieht dabei wie folgt aus:

@Override
public void run() {

	fittedList = new ArrayList<LinkedList<MyObj>>();
	int counter = 0;
	int counterTwo = 0;
        int zoomMultiplikator = this.zoomMulti;
	LinkedList<MyObj> actList = new LinkedList<MyObj>();

	for (LinkedList<MyObj> list : actualData.actualCondensedData) {
		if(counter == zoomMultiplikator){
			if(actList!= null){
				fittedList .add(actList);
			}
				
			actList = new LinkedList<MyObj>();
			counter = 0;
		}
			
	if (counter < zoomMultiplikator) {
		for (MyObj pb : list) {
				if(!actList.contains(pb)){
					actList.add(pb);
				}
			}
			counter++;
		}
			
	counterTwo++;
			
	if(counterTwo%1000 == 0){
		System.out.println("Thread " + counterTwo);
	}
	}
		
	if(actList!= null){
		fittedList.add(actList);
	}
		
	System.out.println(" ");
	System.out.println("FITTED LIST" + fittedList.size());
	}

Also im grund mache ich hier nur folgendes,
Ich besitze eine ArraList<LinkedList<MyObj>>, diese darin befindlichen MyObj-Objekte möchte ich je nach ZoomStufe in eine neue ArraList<LinkedList<MyObj>> speichern, wobei mehrere Einträge der ursprünglichen Daten zu einem Eintrag zusammen gefasst wurden.


Wenn ich dies jetzt aber aufrufe, und ich mir den counterTwo ausgebe, dann sehe ich dass die Zahl mal höher und mal kleiner ist, folglich wurde der Thread dann mehrmals gestartet?

Bei dem AUfruf des Thread für ich aber folgende Kontrolle druch:

public void startThread(final int fitMulti) {
		
		// interrupts the actual Thread
		if (this.activeThread != null){
			if(activeThread.isAlive()){
				System.out.println("Actual Thread is alive - interrupt thread");
				activeThread.interrupt();
			}
		} 
		
		{
			FittedThread thread = new FittedThread(data.actualData, fitMulti);
			thread.start();	
			this.activeThread = thread;
		}
	}

Hat mir jemand einen Tip?

 

[SlaterB]

Formatierung ist nicht so dein Ding, was?

----

in startThread() wird immer ein neuer Thread gestartet, fehlt vielleicht das Wörtchen 'else'?

> activeThread.interrupt();

wird keinen Thread besonders beeindrucken, falls du darauf spekulierst
(man darf fröhlich raten )

------

wenn du dir nicht sicher bist, ob mehrere Thread gestartet wurden,
dann schreibe doch zu Beginn der run-Methode
System.out.println("ein neuer Thread erblickt das Licht der Welt");

 

[redbomber]

ja also startThread() soll immer dann aufgerufen werden, wenn die Berechnungen des aktuell laufenden Threads "nicht mehr nützlich" sind. Also soll dieser gestoppt werden und dafür ein neuer Thread mit den neuen Daten gestartet werden.

Wie kann ich dann den alten Thread beenden?
Die Daten dieses Threads sind für mich komplett unwichtig!
.stop() habe ich gelesen soll man sparsam verwenden.

 

[SlaterB]

du erstellst dir eine eigene Klasse für diesen Thread bzw. hast du ja schon (FittedThread),
setzt von außen ein boolean hoerMalAuf auf true
und in der run()-Methode schaut der Thread selber ab und zu auf dieses Feld
(besonders in Schleifen), wenn true, dann hört er auf, sonst nicht

anders gehts nicht (gut)

 

[redbomber]

Also irgendwie bekommen ich das mal wieder nicht hin.

Von aussen setze ich VOR dem Aufruf eines neuen Threads seine boolean Variable auf true:

hier folgt meine run() Methode:

protected boolean running = false;


@Override
public void run() {
	System.out.println("-----------------------------------------------------");
	System.out.println("NEW THREAD STARTING " + this.threadId);
	System.out.println("-----------------------------------------------------");

	fittedObjects = new ArrayList<LinkedList<Objects>>();
	int counter = 0;
	int counterTwo = 0;
	LinkedList<Objects> actList = new LinkedList<Objects>();

	for (LinkedList<Objects> list : actualData.getAllFitted()) {
		if (counter == zoomMultiplikator) {
			if (actList != null) {
				fittedObjects.add(actList);
			}

			actList = new LinkedList<Objects>();
			counter = 0;
		}
		if (counter < zoomMultiplikator) {
			for (Objects ob : list) {
				if (!actList.contains(ob)) {
					actList.add(ob);
				}
			}
			counter++;
			}

		counterTwo++;

		if (counterTwo % 1000 == 0) {
			System.out.println("Thread " + this.threadId + " Counter: "+ counterTwo);
		}
	}
}

     if (actList != null) {
	fittedObjects.add(actList);
     }
}

Und zwar wo soll ich hier die Abfrage nach dem boolean running einfügen?
Egal wo ich die Abfrage reinsetze, der Thread läuft weiter.


Ich habe mir eine LinkedList<MyThread> erstellt, in die ich alle Threads einfüge.
Wird ein neuer Thread gestartet, dann gehe ich über die Liste und setze von allen Threads den boolean auf false (da diese Threads dann wertlos für mich werden).
Danach starte ich dann den neuen Thread mit den neuen Daten.

Tja, aber bei mir laufen alle Threads einfach weiter!