黑马程序员技术交流社区

标题: 线程同步问题 [打印本页]

作者: 随风永夜    时间: 2014-12-16 18:34
标题: 线程同步问题
class Res
{
        String name;
        String sex;
        boolean flag = false;
}

class Input implements Runnable
{
        private Res r ;
        Input(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                int x = 0;
                while(true)
                {
                        synchronized(r)
                        {
                                if(r.flag)
                                        try{r.wait();}catch(Exception e){}
                                if(x==0)
                                {
                                        r.name="mike";
                                        r.sex="man";
                                }
                                else
                                {
                                        r.name="丽丽";
                                        r.sex = "女女女女女";
                                }
                                x = (x+1)%2;
                                r.flag = true;
                                r.notify();
                        }
                }
        }
}

class Output implements Runnable
{
        private Res r ;       
        Output(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                while(true)
                {
                        synchronized(r)
                        {
                                if(!r.flag)
                                        try{r.wait();}catch(Exception e){}
                                System.out.println(r.name+"...."+r.sex);
                                r.flag = false;
                                r.notify();
                        }
                }
        }
}


class Demo
{
        public static void main(String[] args)
        {
                Res r = new Res();
                Input in = new Input(r);
                Output out = new Output(r);
                Thread t1 = new Thread(in);
                Thread t2 = new Thread(out);
                t1.start();
                t2.start();
        }
}

求问下   同步有锁 那不是一次只有一个线程能进去操作 ,那么如果有一个等待第2个怎么进去 进不去怎么唤醒等待的线程。
作者: zhaozhao    时间: 2014-12-16 19:58
在毕老师java基础第146期不是有一个“生产者消费者”的例子吗?在jdk1.5之前是用notify(),notifyAll();唤醒线程的!不过nodify();唤醒的是队列中的等待线程,不能分对象唤醒线程!而jdk1.5之后,可以用Condition对象代替了notify()!唤醒进程更具灵活性!
作者: 随风永夜    时间: 2015-4-14 15:08
忘记了   wait()方法会放弃执行权!




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