黑马程序员技术交流社区

标题: 线程通信-锁唤醒机制（练习） [打印本页]

---

作者: zhoubinjian    时间: 2016-4-7 17:33
标题: 线程通信-锁唤醒机制（练习）
JDK1.5的新特性：提供了线程升级解决方案
1.Lock代替了synchronized
2.Condition代替了Object监视器方法,将（wait,notify,notifyAll）封装成Condition对象，Condition对象可以生成多个，也就是说可以有多组（wait,notify,notifyAll），可以调用唤醒对方的函数
3.该对象可以通过Lock锁进行获取。


import java.util.concurrent.locks.*;
class Res
{
        private String name;
        private String sex;
        boolean flag=false;
        private Lock lock=new ReentrantLock();
        private Condition condition_ru = lock.newCondition();
        private Condition condition_chu = lock.newCondition();

        public void setNum(String name,String sex)throws InterruptedException
        {
                lock.lock();
                try
                {
                        while(flag)
                       
                                condition_ru.await();
                        this.name=name;
                        this.sex=sex;
                        flag=true;
                        condition_chu.signal();
                       
                }
                               
               
                finally
                {
                        lock.unlock();
                }
        }
        public void out()throws InterruptedException
        {
                lock.lock();
                try
                {
                        while(!flag)
                       
                                condition_chu.await();
                                System.out.println(name+"----"+sex);
                        flag=false;
                        condition_ru.signal();
                       
                }                               
               
                finally
                {
                        lock.unlock();
                }
        }
}
class Intput implements Runnable
{
        private Res r;
        Intput(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                int x=0;
                while(true)
                {       
                        try{
                                        if(x==0)                               
                                                r.setNum("zhoubin","men");                                               
                                        else                               
                                                r.setNum("lili","women");                               
                                        x=(x+1)%2;
                                }
                                catch(InterruptedException e){}
                       
                }
        }
}

class Output implements Runnable
{
        private Res r;
        Output(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                while(true)
                {
                        try{
                                r.out();
                           }
                           catch(InterruptedException e){}
                }
        }
}

class Demo
{
        public static void main(String[] args)
                {
                       
                        Res r=new Res();
                        new Thread(new Intput(r)).start();
                        new Thread(new Output(r)).start();
                        //new Thread(new Output(r)).start();
                        //new Thread(new Output(r)).start();

                        /*
                        Intput in=new Intput(r);
                        Output ou=new Output(r);
               
                        Thread t1=new Thread(in);
                        Thread t2=new Thread(ou);
                       
                        t1.start();
                        t2.start();
                        */
                }
}

1463.tmp.png (75.9 KB, 下载次数: 7)

下载附件

2016-4-7 17:30 上传

---

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

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