[已解决]关于java锁的问题

萌萌哒的小虎崽 · 发表于 2020-4-20 12:03:01

马上注册，结交更多好友，享用更多功能^_^

您需要登录才可以下载或查看，没有账号？立即注册

x

Java中刚刚释放掉锁的线程在再次抢锁的速度上是不是会有优势啊？看这里的执行结果，一直都是两个线程连续执行两次，是巧合吗还是？

package com.dayuanit.lesson049;

public class testlesson049 {
        
        //false--说明篮子为空 true--说明篮子不为空
        public static boolean flag = false;
        
        public static Object lock = new Object();//定义一把全局使用的锁
        
        public static void main(String[] args) {
                // TODO Auto-generated method stub
                
                //生产者线程和消费者线程
                
                Thread producerThread = new Thread(new ProducerThread(), "producer thread");
                Thread customerThread = new Thread(new CustomerThread(), "customer thread");
                
                producerThread.start();
                customerThread.start();
        }

}

class ProducerThread  implements Runnable {
        public void run() {
                
                //不停的进行生产消费
                while (true) {
                        //需要先对全局的锁锁上，使用wait方法需要这一步，即释放这把锁
                        synchronized (testlesson049.lock) {
                                //先进行一次判断，如果篮子是有东西的，作为生产者停止向篮子里装东西，等待消费者消费
                                if (testlesson049.flag == true) {
                                        
                                        try {
                                                System.out.println("篮子是满的，消费者快来消费啊！！");
                                                System.out.println("-----------------------------");
                                                testlesson049.lock.wait();//等待机制
                                        } catch (InterruptedException e) {
                                                // TODO Auto-generated catch block
                                                e.printStackTrace();
                                        }
                                }
                                
                                System.out.println("我是生产者，我能跑！！！");
                                
                                //往篮子里装东西
                                testlesson049.flag = true;
                                System.out.println(testlesson049.flag);
                                System.out.println("-----------------------------");
                                
                                
                                //执行完毕后稍微休息一下
                                try {
                                        Thread.sleep(2 * 1000);
                                } catch (InterruptedException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                                //告诉所有等待的线程，生产者的任务完成了
                                testlesson049.lock.notifyAll();
                        }
                }
        }
}

class CustomerThread  implements Runnable {
        public void run() {
                
                //不停的进行生产消费
                while (true) {
                        //需要先对全局的锁锁上，不然会出问题
                        synchronized (testlesson049.lock) {
                                //先进行一次判断，如果篮子为空，作为消费者停止从篮子里取东西，等待生产者生产
                                if (testlesson049.flag == false) {
                                        try {
                                                System.out.println("篮子是空的，生产者快干活啊！！");
                                                System.out.println("-----------------------------");
                                                testlesson049.lock.wait();
                                        } catch (InterruptedException e) {
                                                // TODO Auto-generated catch block
                                                e.printStackTrace();
                                        }
                                }
                                
                                System.out.println("我是消费者，我拿到东西了！！！");
                                
                                //从篮子里取走东西
                                testlesson049.flag = false;
                                System.out.println(testlesson049.flag);
                                System.out.println("-----------------------------");
                                
                                //执行完毕后稍微休息一下
                                try {
                                        Thread.sleep(2 * 1000);
                                } catch (InterruptedException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                                //通知所有等待这把锁的线程，你们可以继续使用这把锁了
                                testlesson049.lock.notifyAll();
                        }
                }
        }
                
                
}

最佳答案

月排行榜 / 总排行榜

倒戈卸甲

2020-4-20 14:22:25