Java-Где использовать wait in Consumer

Question

Я пытаюсь реализовать pGm-производитель-потребитель. Общий ресурс - очередь (массив объектов - размер 5). Продюсер добавляет объект и уведомляет Потребителя, когда q полностью ждет. Потребитель ждет, когда q пуст, иначе читает/удаляет и уведомляет производителя о том, что это сделано.

Что я не в состоянии понять,

1. Когда оповещает Producer после добавления OBJ, потребитель не будет в состоянии ожидания, так что производитель продолжает производить, пока д полна.

Может ли кто-нибудь помочь вам, как это преодолеть. Я знаю, что где-то просто отсутствует, но я не в состоянии наряжать :(

class Queue 
{ 
    public void add(Object item) 
    { 
    q[index] = item; 
    index++; 
    } 
    public Object get() 
    { 
    Object item = q[index - 1]; 
    index--; 
    return item; 
    } 
    public boolean isQfull() 
    { 
System.out.println("Queue:index-->" + index); 
if(index == 5) 
{ 
return true; 
} 
return false; 
    } 

    public boolean isQEmpty() 
    { 
    if(index == 0) 
{ 
System.out.println("Queue:isQEmpty"); 
return true;   
} 
return false; 
    } 
} 

class Producer extends Thread 
{ 
public void run() 
{ 
    synchronized(q) 
    { 
    for(int i=0;i<20;i++) 
    { 
    if(q.isQfull()) 
    { 
    q.wait(); 
    } 
    else 
    { 
    q.add(i);      
    q.notify();       
    } 
    } 
} 
} 
public class Consumer extends Thread 
{ 
public void run() 
{ 
    synchronized(q) 
    { 
    while(true) 
{ 
if(q.isQEmpty()) 
{ 
    q.wait();      
} 
else 
{ 
System.out.println("Consumer consuming" + q.get()); 
q.notify(); 
} 
    } 
    } 
} 

}

Answer 1

http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/BlockingQueue.html

Вы рассматривали использование очереди из параллельного пакета Java? Вам не придется вручную синхронизировать производитель и потребитель

EDIT:.

В этом случае вы можете забыть о синхронизации вашего продюсера а, й потребитель. Вместо этого, ваш класс очереди синхронизирует свои добавления и вызовы.

class Queue 
private final Object lock = new Object(); 
{ 
    public void add(Object item) 
    { 
    synchronized(lock) { 
     q[index] = item; 
     index++; 
    } 
    } 
    public Object get() 
    { 
    synchronized(lock) { 
     Object item = q[index - 1]; 
     index--; 
     return item; 
    } 
    } 
} 

Answer 2

Этот вопрос нуждается повторно формулировка, но я считаю, что вопрос (связана с тем, что выглядит как домашнее задание) ...

«Что я не в состоянии понять, является 1) Когда извещает Producer после добавления obj потребитель не будет в состоянии ожидания, так что продюсер продолжает производить до тех пор, пока q не будет заполнен. Может кто-нибудь PLZ помочь, как преодолеть это ».

Логика для класса Продюсера кажется ясной, а реализация обоснованно правильной. То есть, Продюсер не заботится о деятельности Потребителя только в том, что Очередь остается полной. Предполагая, что Thread периодически запускается(), чтобы повторно заполнить очередность, в которой пользователи удаляют записи, Producer не должен ждать(), но просто выйдите, если очередь заполнена.

Таким образом:

if (!q.isFull()) 
... add to queue and notify Consumers. 

Чего не хватает здесь есть на стороне потребителя, который должен ждать() или чек-обратно периодически, если очередь пуста (ожидание Производителю пополнения очереди).