我能否获得实现这一目标的明确方法。我使用了join并等待替代生产者和消费者执行。在一次采访中询问了这个问题。他不喜欢我的解决方案。我还在同步块中建议了一个用于消耗/生成资源的循环。
以下是预期产量:
p1 c1 p3 c1 p2 c1 p2 c1。 。 。
import java.util.concurrent.atomic.AtomicInteger;
public class TestClient {
public static void main(String[] args) {
ProducerConsumerUtilClass pcuc=new ProducerConsumerUtilClass();
Thread producer1= new Thread(new Runnable() {
@Override
public void run() {
while(true) {
try {
Thread.sleep(1000);
pcuc.produce();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
});
Thread producer2= new Thread(new Runnable() {
@Override
public void run() {
while(true) {
try {
Thread.sleep(1000);
pcuc.produce();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
});
Thread producer3= new Thread(new Runnable() {
@Override
public void run() {
while(true) {
try {
Thread.sleep(1000);
pcuc.produce();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
});
Thread consumer1= new Thread(new Runnable() {
@Override
public void run() {
while(true) {
try {
Thread.sleep(1000);
pcuc.consume();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
});
producer1.start();
producer2.start();
producer3.start();
consumer1.start();
}
}
class ProducerConsumerUtilClass {
Object obj= new Object();
private volatile boolean available;
private AtomicInteger atomicInteger=null;
public ProducerConsumerUtilClass() {
this.available = false;;
this.atomicInteger = new AtomicInteger(0);;
}
public void produce() {
synchronized (obj) {
while(available) {
try {
obj.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
System.out.println("Produce By "+Thread.currentThread().getName()+"Value "+atomicInteger.getAndIncrement());
this.available=true;
obj.notifyAll();
}
}
public void consume() {
synchronized (obj) {
while(!available) {
try {
obj.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
System.out.println("Consume By "+Thread.currentThread().getName()+"Value "+atomicInteger.getAndIncrement());
this.available=false;
obj.notifyAll();
}
}
}