JAVASE中的多线程小结,多生产多消费案例.

 Thread t= new Thread();
 t.start();
 //如果这样做，start方法调用的是Thread类中的run方法，而这个线程中的run方法没有做什么事情
 //更重要的是这个run方法中并没有定义我们需要让线程执行的代码

public class ThreadDemo1{
    //多生产与多消费  ---多线程案例
    /*
    生产一个资源，消费一个资源
    当有资源时，则消费，无资源时，则生产
    
    定义标记来标记当前是否有资源，如果标记为true，则代表有资源，生产者先告诉消费者来消费
    然后再进去到等待状态，如果标记为false，则代表没有资源，消费者来告诉生产者生产资源，然后再去等待
    
    问题1：被唤醒的线程没有继续判断标记，所以会造成一个生产者生产多个一个消费者消费多个，
    我们只需要吧if改为while进行多次判断即可解决。
    问题2：出现死锁即全部等待状态，因为没有办法指定唤醒哪个线程所以我们只能把所有的线程全部唤醒notifyAll。
    
    提升效率：Lock实现提供了比使用synchronized方法和语句可获得的更广泛的锁定操作，此实现允许更加灵活的结构，可以具有
    差别很大的属性。
    */
    public static void main(String[] args){
        //创建资源对象
        Resource r=new Resource();
        //创建线程任务
        Producer p=new Producer(r);
        Consumer c=new Consumer(r);
        //创建线程
        Thread t1 = new Thread(p);//负责生产
        Thread t2 = new Thread(c);//负责消费
        Thread t3 = new Thread(p);//负责生产
        Thread t4 = new Thread(c);//负责消费
        //开启线程
        t1.start();
        t2.start();
        t3.start();
        t4.start();
    }
}
//描述资源
class Resource{
    //属性：名字 编号
    private String name;
    private int count = 1;
    //定义锁对象
    private Lock lock = new ReentrantLock();
    private Condition p = lock.newCondition();//生产者
    private Condition c = lock.newCondition();//消费者
    //定义标记
    private boolean flag=false;
    //方法:对资源名字赋值set   获取资源get
    public void set(String name){
        //获取锁
        lock.lock();
        try{
            while(flag){//当为true则代表有资源,生产者等待
                try{
                    //wait();
                    /*
                    之前的wait的锁对象是this，现在的锁已经是lock了，所以需要方法来作用到新锁上，将之前原有的
                    所有方法封装在Condition对象中，想要获取方法，首先获取Condition对象
                    
                    希望本方唤醒对方中的一个，一个锁，但是操作线程状态的方法不止一个，可以在一个锁上挂多个监视
                    器对象
                    */
                    c.await();
                }catch(){
                
                }
            }
            this.name=name+count;
            count++;
            System.out.println(Thread.currentThread().getName()+"生产者"+this.name);
            //将标记改为true
            flag=true;
            //叫醒消费者的任意一个
            //notifyAll();
            c.signalAll();
        }finally{
            lock.unlock();
        }
    }
    public void get(){
        lock.lock();
        try{
            while(!flag){//flag为false则代表没资源，消费者等待
                try{
                    //wait();
                    p.await();
                }catch(){
                
                }
            }
            System.out.println(Thread.currentThread().getName()+"消费者"+this.name);
            //将标记改为false
            flag=false;
            //叫醒生产者的任意一个
            //notifyAll();
            p.signalAll();
        }finally{
            lock.unlock();
        }
    }
}

//描述生产者
class Producer implements Runnable{
    private Resource r;
    public Producer(Resource r){
        this.r=r;
    }
    
    public void run(){
        //生产资源
        while(true){
            r.set("寿司");
        }
        
    }
}

//描述消费者
class Consumer implements Runnable{
    private Resource r;
    public Consumer(Resource r){
       this.r=r;
    }
    public void run(){
       //消费资源
       while(true){
           r.get("寿司")
       }
     }
}