生产者-消费者模式

• 生产者负责生产产品。
• 消费者负责取走并使用产品。
• 生产者生产完成后通知消费者可以取走产品了。
• 消费者消费完产品后需要通知生产者生产产品。
• 生产者没有生产完成，消费者不能取走产品。
• 消费者没有使用完产品，生产者不能生产产品。

package Main;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;

class Product
{
    private Object lockObj = new Object();
    private String name;
    private String content;
    private boolean available = false;
    
    public void setInfo(String name, String content)
    {
        synchronized(this.lockObj)
        {
            if(this.available == true) //可以获取 不能生产
            {
                try
                {
                    this.lockObj.wait();
                }catch(Exception e)
                {}
            }
            
            
            this.name = name;
            try
            {
                Thread.sleep(200);
            }catch(Exception ignore)
            {}
            
            this.content = content;
            
            this.available = true;//生产完成
            this.lockObj.notifyAll();
        }
    }
    
    public void showInfo()
    {
        StringBuffer info = new StringBuffer();
        synchronized(this.lockObj)
        {
            if(this.available == false)
            {
                try
                {
                    this.lockObj.wait();
                }catch(Exception e)
                {}
            }
            info.append("name:").append(this.name);
            try
            {
                Thread.sleep(100);
            }catch(Exception e)
            {}
            info.append(" content:" + this.content);
            System.out.println(info.toString());
            this.available = false;
            this.lockObj.notifyAll();
        }
    }
}

class Producer implements Runnable
{
    private Product product ;
    public Producer(Product product)
    {
        this.product = product;
    }
    
    @Override
    public void run()
    {
        for(int i = 1; i <= 100; i ++)
        {
            if(i % 2 ==0)
            {
                this.product.setInfo("笔记本", "惠普笔记本，妈妈再也不用担心冬天没暖气了");
            }else
            {
                this.product.setInfo("Galaxy Note7", "出门旅行，杀人灭口必备武器");
            }
        }
    }
}

class Consumer implements Runnable
{
    private Product product ;
    public Consumer(Product product)
    {
        this.product = product;
    }
    
    @Override
    public void run()
    {
        for(int i =1; i <= 100; i++)
        {
            this.product.showInfo();
        }
    }
}

public class Main
{
    public static void main(String[] args) throws Exception
    {
         Product product = new Product();
         Producer producer = new Producer(product);
         Consumer consumer = new Consumer(product);
         Thread tProducer = new Thread(producer);
         Thread tConsumer = new Thread(consumer);
        
         tProducer.start();
         tConsumer.start();
         tProducer.join();
         tConsumer.join();
        
        System.out.println("Main Done//~~");
    }
}