JAVA多线程实现生产者消费者的实例详解

JAVA多线程实现生产者消费者的实例详解

下面的代码实现了生产者消费者的问题

Product.Java

package consumerProducer;
public class Product {
private String id;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public Product(String id)
{
this.id=id;
}
public String toString()
{
return "product "+id;
}
}

Pool.java

package consumerProducer;
import java.util.*;
public class Pool {
private int number=0;
private List<Product>products=new LinkedList<Product>();
public int getNumber() {
return number;
}
public void setNumber(int number) {
this.number = number;
}
public synchronized Product consumeProduct(){  //可以去掉synchronized关键字
if(products.size()>0)
{    Product p= products.get(0);
products.remove(0);
number--;
return p;
}
else
return null;
}
public synchronized void addProduct(Product p){  //可以去掉synchronized关键字
products.add(p);
number++;
}
}

Consumer.java

package consumerProducer;
public class Consumer implements Runnable {
private String id;
Pool pool;
public Consumer(String id,Pool pool)
{
this.id=id;
this.pool=pool;
}
@Override
public void run() {
while(!Thread.currentThread().interrupted())
{
Product product=null;
synchronized(pool){
while(pool.getNumber()<=0)//生产不足
{
try {
pool.wait();//生产者等待
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
product=pool.consumeProduct();
}
System.out.println("consuming "+id+product.toString());
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}

Producer.java

package consumerProducer;
public class Producer implements Runnable{
private int i_p=0;
private String id;
Pool pool;
int i=0;
public Producer(String id ,Pool pool)
{
this.id=id;
this.pool=pool;
}
public Product createProduct()
{
return new Product(String.valueOf(++i_p));
}
@Override
public void run() {
// TODO Auto-generated method stub
while(!Thread.currentThread().interrupted())
{
Product p=new Product(String.valueOf(++i_p));
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
synchronized(pool)
{
pool.addProduct(p);
System.out.println("producer "+id+" adding product...."+p.toString());
pool.notifyAll();
}
}
}
}

Main.java

package consumerProducer;
public class Main {
public static void main(String[] args) {
// TODO Auto-generated method stub
Pool pool=new Pool();
for(int i=0;i<5;i++)
{
Thread consumer=new Thread(new Consumer("consumer "+i,pool));
Thread producer=new Thread(new Producer("producer "+i,pool));
consumer.start();
producer.start();
}
}
}

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

您可能感兴趣的文章:

• java并发学习之BlockingQueue实现生产者消费者详解
• JAVA生产者消费者(线程同步)代码学习示例
• java多线程解决生产者消费者问题
• java解决单缓冲生产者消费者问题示例
• 基于Java 生产者消费者模式(详细分析)
• Java多线程之线程通信生产者消费者模式及等待唤醒机制代码详解
• Java实现生产者消费者问题与读者写者问题详解
• java 中多线程生产者消费者问题详细介绍
• Java锁机制Lock用法示例
• Java基于Lock的生产者消费者模型示例