QUEUE und Threads

[GASTi]

Hi,

Ich habe eine Queue, diese fülle ich in dem "MainObjekt". und Eine Thread, die die Referenz der queue hat.
Wenn ich im Thread die queue größe überprüfe, wird ein wert > 0 zurückgegeben, also versuche ich den ersten wert rauszuholen und zu verarbeiten. Aber ich bekomme trozdem eine NoSuchElementException.
Das ich eine Exception erhalte ist allerdings sehr sehr selten

Hat jemand vielleicht eine idee wieso das so ist?

-> am Thread doch eigentlich nicht? da eine seite reinschreibt und die andere nur wieder rausholt

 

[SlaterB]

ich habe ein Programm, dass an einer Stelle, die eigentlich rot malen, etwas grün darstellt,
wenn du dazu jetzt die korrekte Lösung lieferst, verspreche ich, auch für dein Programm haargenau jeden Fehler zu identifizieren

-----

anderenfalls kann man mit richtiger Arbeit anfangen, z.B. ein Testprogramm posten

 

[Nader]

Hi,

Ich habe eine Queue, diese fülle ich in dem "MainObjekt". und Eine Thread, die die Referenz der queue hat.
Wenn ich im Thread die queue größe überprüfe, wird ein wert > 0 zurückgegeben, also versuche ich den ersten wert rauszuholen und zu verarbeiten. Aber ich bekomme trozdem eine NoSuchElementException.
Das ich eine Exception erhalte ist allerdings sehr sehr selten

Hat jemand vielleicht eine idee wieso das so ist?

-> am Thread doch eigentlich nicht? da eine seite reinschreibt und die andere nur wieder rausholt

du solltest deine Queue Thread Safe machen! zb. so:

class MeinObjekt {
   
   public void synchronized fuelleQueue() {
        synchronized(queue) {
             // fülle queue
        }
   }
}

class MyThread extends Thread {
   public void run() {
        synchronized(queue) {
             // aus queue lesen
        }
   }
}

 

[Unregistriert]

ich habe ein Programm, dass an einer Stelle, die eigentlich rot malen, etwas grün darstellt,
wenn du dazu jetzt die korrekte Lösung lieferst, verspreche ich, auch für dein Programm haargenau jeden Fehler zu identifizieren

haha.... farbcode verwechselt xD oder monitor pins verbogen ;-)

private Queue<Obj> q = new LinkedList<Obj>();

private IrgendeineThread t = new IrgendeineThread();
[...]
public MainObj() {
   t.setQueue(q);
}

public void doSomething() {
   q.add(new Obj(123));
}

class IrgendeineThread extends Thread
{
   [..]
   private queue q;

   public void run() {
      if(q.size() > 0) {
          q.poll();   // hier tritt die exception auf ..... unverständlich weil ich ja vorher geprüft habe ob elemente vorhanden sind
      }
   }
}

Das andere seltsame ist das in der beschreibung von der Queue steht das bei poll keine Exception geschmissen wird sondern lediglich null zurückgegeben wird.

    public void run() {
      if((obj = q.poll() ) != null)
           // verarbeiten
      else {
          Thread.sleep(x); 
     }
   }

Hier habe ich die Exception noch nie bekommen aber was kann size denn so verändern das bei poll auf einmal eine Exception geschmissen wird ?

 

[Michael...]

Hatte zwar mit Queues nix tun, aber probier mal folgendes:

[JAVA=19] public void run() {
synchronized(q) {
if(q.size() > 0) {
q.poll(); // hier tritt die exception auf ..... unverständlich weil ich ja vorher geprüft habe ob elemente vorhanden sind
}
}
}
}
[/code]

 

[SlaterB]

poll von LinkedList lautet

    public E poll() {
        if (size==0)
            return null;
        return removeFirst();
    }

auch da muss also eine Nebenläufigkeit stattfinden, nachdem ein size-Aufruf durchlaufen wurde und das removeFirst() dran ist entfernt jemand anders noch schnell das letzte Element

das synchronized hilft durchaus, wenn sonst nirgendwo auf die Liste zugegriffen wird,
allerdings ist der doppelte Zugriff wahrscheinlich gar nicht gewünscht, jetzt ist interessant wer wo den Thread erzeugt, vielleicht passiert das zweimal, oder mehrere MainObj, die je einen Thread erzeugen usw.,
aus deinem Code ist bisher kein Fehler erkennbar,


bei sowas kann helfen, die fragliche Methode in der Queue zu überschreiben:

public class Test {
	private static LinkedList<Object> q = new LinkedList<Object>() {

		@Override
		public Object poll() {
			System.out.println("call to poll from Thread "
					+ Thread.currentThread());
			return super.poll();
		}

	};

	public static void main(String[] args) {
		q.poll();

		Runnable r = new Runnable() {
			public void run() {
				q.poll();
			}
		};
		new Thread(r).start();
	}
}

->
call to poll from Thread Thread[main,5,main]
call to poll from Thread Thread[Thread-0,5,main]

kann man noch um Systemzeit ergänzen, durch StackTrace die Codezeile ermitteln, oder etwas simpler per
new Error().printStackTrace();

schwieriger wird es, wenn mehrere verschiedene Methoden der LinkedList im Spiel sind..