生产者——消费者模型的java代码实现

生产者

import java.util.Random;


public class Producer extends Thread {

    private Storage<Product> storage;
    
    public Producer(Storage<Product> storage) {
        this.storage = storage;
    }

    @Override
    public void run() {
        produce();
    }

    private void produce() {
        while (true) {
            Product product = new Product(new Random().nextInt(100));
            storage.enStorage(product);
        }
    }

    
}

消费者

public class Consumer extends Thread {

    private Storage<Product> storage;
    
    public Consumer(Storage<Product> storage) {
        this.storage = storage;
    }

    @Override
    public void run() {
        consume();
    }

    private void consume() {
        while (true) {
            storage.deStorage();
        }
    }

    
}

产品

/**
 * 产品
 * 
 * @author thief
 *
 */
public class Product {

    private int id;

    public Product(int id) {
        this.id = id;
    }

    @Override
    public String toString() {
        return "产品：" + id;
    }

}

仓库

import java.util.ArrayList;
import java.util.List;

/**
 * 仓库
 * 
 * @author Thief
 *
 * @param <E>
 */
public class Storage<E> {

    private List<E> list = new ArrayList<E>();

    /**
     * 入仓
     * 
     * @param e
     */
    public void enStorage(E e) {
        synchronized (list) {
            while (this.isFull()) {
                try {
                    System.out.println("仓库已满");
                    list.wait();
                } catch (InterruptedException e1) {
                    e1.printStackTrace();
                }
            }
            list.add(e);
            System.out.println(Thread.currentThread().getName() + "生产产品");
            try {
                Thread.sleep(10);
            } catch (InterruptedException e1) {
                e1.printStackTrace();
            }
            list.notifyAll();
        }
    }

    /**
     * 出仓
     * 
     * @param e
     */
    public E deStorage() {
        synchronized (list) {
            while(this.isEmpty()) {
                try {
                    System.out.println("仓库已空");
                    list.wait();
                } catch (InterruptedException e1) {
                    e1.printStackTrace();
                }
            }
            E e = list.get(0);
            list.remove(0);
            System.out.println(Thread.currentThread().getName() + "消费产品");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e1) {
                e1.printStackTrace();
            }
            list.notifyAll();
            return e;
        }
    }

    /**
     * 判断当前仓库是否为空
     * 
     * @return
     */
    public boolean isEmpty() {
        return list.isEmpty();
    }

    /**
     * 判断当前仓库是否已满
     * 
     * @return
     */
    public boolean isFull() {
        return list.size() == 5;
    }

}

测试代码

public class Test {
    
    public static void main(String[] args) {
        
        Storage<Product> storage = new Storage<Product>();
        
        new Producer(storage).start();
        new Consumer(storage).start();
    }

}