queue

public class BoundedBuffer
{
  private int upperBound;
  private java.util.LinkedList buffer;

  public BoundedBuffer(int upperBound)
  {
    this.upperBound = upperBound;
    buffer = new java.util.LinkedList();
  }

  public synchronized void push(Object obj)
  {
    //denne while er løsningen på dit problem (guarded suspension)
    while(buffer.size() >= upperBound)
    {
      try
      {
        wait();
      }
      catch(InterruptedException e)
      {
          e.printStackTrace();
      }
    }

    buffer.addLast(obj);

    if(buffer.size() == 1)
      notify(); // væk én tråd, som venter på monitor
    else
      notifyAll(); // væk alle tråde, som venter på monitor
  }

  public synchronized Object pop()
  {
    while(buffer.size() == 0)
    {
      try
      {
        wait();
      }
      catch(InterruptedException e)
      {
          e.printStackTrace();
      }
    }

    Object obj = buffer.removeFirst();

    if(buffer.size() < upperBound)
      notifyAll(); // væk alle tråde, som venter på monitor

    return obj;
  }
}

så opretter du en klasse der sender objekter ind i bufferen (en producer) og en klasse der tager ud af bufferen (en consumer).

hmmm, løsningen på dit problem er faktisk i pop metodens while.. :-)

et eks. på producer, consumer og en main som benytter bufferen:

public class Producer extends Thread
{
  BoundedBuffer buffer;

  public Producer(BoundedBuffer buffer)
  {
    this.buffer = buffer;
  }

  public void run()
  {
    int n = 0;
    while(true)
    {
      buffer.push(new Integer(n));
      n++;
    }
  }
}

public class Consumer extends Thread
{
  BoundedBuffer buffer;

  public Consumer(BoundedBuffer buffer)
  {
    this.buffer = buffer;
  }

  public void run()
  {
    Object obj;
    while(true)
    {
      obj = buffer.pop();
      System.out.println("Hentede: " + obj);
    }
  }
}

public class Main
{
  public static void main(String args[])
  {
    BoundedBuffer buffer = new BoundedBuffer(10);//værdi valgt tilfældigt

    Producer p1 = new Producer(buffer);
    Consumer c1 = new Consumer(buffer);

    p1.start();
    c1.start();
  }
}

takker =) fandt lige ud af at problemet var at jeg ikke holdte den samme monitor når jeg forsøgte at notify() som når min tråd waitede.