| 本帖最后由 周兴中 于 2012-6-27 11:45 编辑 
 当一个线程进入一个对象的一个synchronized方法后,其他线程也无法进入其对象的其他方法(根本进入不了任何方法),因为在同一个时间内,只有一个线程有CPU执行权,而同步synchronized之后的方法,是为了让CPU执行完被同步的方法之后,释放执行权,然后再和其他线程一起竞争CPU执行权,谁拿到执行权,谁才再有执行的权利.
 如果不加同步修饰,那么当执行到某个方法的一部分语句之后,就有可能被其他CPU抢到执行权,那么容易出现错误(在操作共享数据时).
 可以参考生产者和消费者代码:
 复制代码
class ProducerConsumerDemo 
{
        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();
        }
}
/*
对于多个生产者和消费者。
为什么要定义while判断标记。
原因:让被唤醒的线程再一次判断标记。
为什么定义notifyAll,
因为需要唤醒对方线程。
因为只用notify,容易出现只唤醒本方线程的情况。导致程序中的所有线程都等待。
*/
class Resource
{
        private String name;
        private int count = 1;
        private boolean flag = false;
                        //  t1    t2
        public synchronized void set(String name)
        {
                while(flag)
                        try{this.wait();}catch(Exception e){}//t1(放弃资格)  t2(获取资格)
                this.name = name+"--"+count++;
                System.out.println(Thread.currentThread().getName()+"...生产者.."+this.name);
                flag = true;
                this.notifyAll();
        }
        //  t3   t4  
        public synchronized void out()
        {
                while(!flag)
                        try{wait();}catch(Exception e){}//t3(放弃资格) t4(放弃资格)
                System.out.println(Thread.currentThread().getName()+"...消费者........."+this.name);
                flag = false;
                this.notifyAll();
        }
}
class Producer implements Runnable
{
        private Resource res;
        Producer(Resource res)
        {
                this.res = res;
        }
        public void run()
        {
                while(true)
                {
                        res.set("+商品+");
                }
        }
}
class Consumer implements Runnable
{
        private Resource res;
        Consumer(Resource res)
        {
                this.res = res;
        }
        public void run()
        {
                while(true)
                {
                        res.out();
                }
        }
}
 |