黑马程序员技术交流社区

标题: jdk 5.0中的消费生产代码 [打印本页]

---

作者: fenger7    时间: 2015-10-17 11:38
标题: jdk 5.0中的消费生产代码
jdk5.0中的消费生产代码
import java.util.concurrent.locks.*;

class ProducerConsumerDemo2
{
        public static void main(String[] args)
        {
                Resource r=new Resource();

                Producer pro=new Producer(r);
                Consumer con=new Consumer(r);
   
            Thread t1=new Thread(pro);
                Thread t2=new Thread(pro);
                Thread t3=new Thread(con);
                Thread t4=new Thread(con);

                t1.start();
                t2.start();
                t3.start();
                t4.start();
        }

}

class Resource
{
        private String name;
        private int count=1;
        private boolean flag=false;

        private Lock lock=new ReentrantLock();

        private Condition condition_pro=lock.newCondition();
        private Condition condition_con=lock.newCondition();

        public void set(String name) throws InterruptedException
        {
                lock.lock();
                try
                {
                        while(flag)
                             condition_pro.await();
                    this.name=name+"--"+count++;

                    System.out.println(Thread.currentThread().getName()+"...Producer..."+this.name);
                    flag=true;
                    condition_con.signal();
                }
                finally
                {
                        lock.unlock();
                }
               
        }


    public synchronized void out() throws InterruptedException
        {
                lock.lock();
                try
                {
                        while(!flag)
                            condition_con.await();
                    System.out.println(Thread.currentThread().getName()+"......Consumer......"+this.name);
                    flag=false;
                    condition_pro.signal();
                }
                finally
                {
                        lock.unlock();
                }
        }
}


class Producer implements Runnable
{
        private Resource res;

        Producer(Resource res)
        {
                this.res=res;
        }
        public void run()
        {
                while(true)
                {
                        try
                        {
                                res.set("thing");
                        }
                        catch (InterruptedException e)
                        {
                        }
                }
        }
}
class Consumer implements Runnable
{
        private Resource res;

    Consumer(Resource res)
        {
                this.res=res;
        }
        public void run()
        {
                while(true)
                {
                        try
                        {
                                res.out();
                        }
                        catch (InterruptedException e)
                        {
                        }
                }
        }
}

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2