zoukankan      html  css  js  c++  java
  • synchronized与ReentrantLock实现共享资源的消费

    主方法

    public class synchronizedTest {
        public static void main(String[] args) {
            long startTime = System.currentTimeMillis();  
            TicketSystem ticketSystem=new TicketSystem();
            Thread  t1=new Thread(ticketSystem);
            Thread  t2=new Thread(ticketSystem);
            Thread  t3=new Thread(ticketSystem);
            Thread  t4=new Thread(ticketSystem);
            t1.setName("1号售票点");
            t2.setName("2号售票点");
            t3.setName("3号售票点");
            t4.setName("4号售票点");
            t1.start();
            t2.start();
            t3.start();
            t4.start();
            while (true) {
                if(ticketSystem.getTicKetNumber()<=0){
                    long endTime = System.currentTimeMillis();  
                    float seconds = (endTime - startTime) / 1000F;  
                    System.out.println(Float.toString(seconds) + " seconds."); 
                    break;
                }
            }
        }
    }

    synchronized线程方法1:

    public class TicketSystem implements Runnable {
    
        private static volatile int ticketNumber = 900;
    
    
        public int getTicKetNumber() {
            return this.ticketNumber;
        }
    
        @Override
        public synchronized  void run() {
            while (true) {
                if (ticketNumber <= 0) {
                    break;
                } else {
                    System.out.println(Thread.currentThread().getName() + "卖了最后第" + ticketNumber + "票");
                    ticketNumber--;
                }
            }
        }
    
    }

    ReentrantLock线程方法2:

    public class TicketSystem implements Runnable {
    
        private static volatile int ticketNumber = 900;
    
        private ReentrantLock lock = new ReentrantLock();
    
        public int getTicKetNumber() {
            return this.ticketNumber;
        }
    
        @Override
        public void run() {
            while (true) {
                lock.lock();
                if (ticketNumber <= 0) {
                    break;
                } else {
                    System.out.println(Thread.currentThread().getName() + "卖了最后第" + ticketNumber + "票");
                    ticketNumber--;
                }
                lock.unlock();
            }
        }
    
    }

    总结:

    synchronized在这里将run()方法加入了锁,其他线程方法时如果当前锁没有释放进去等待状态等线程释放锁后进入锁的争夺。每次只允许一个线程访问。

    ReentrantLock 利用lock.lock()获得锁,lock.unlock()释放锁,实现与synchronized同样的效果。

  • 相关阅读:
    Unknown type name 'class'; did you mean 'Class'? 问题的解决
    pxe+kickstart无人值守批量安装linux
    从图片中的一点取色
    结合UIImageView实现图片的移动和缩放
    把UIColor对象转化成UIImage对象
    iPhone:constrainedToSize获取字符串的宽高 自定义label的高度和宽度
    UITextField详解
    Iphone通过viewDidLoad设置拉伸图像与按钮样式
    iPhone 利用CG API画一个饼图(Pie chart)
    UILabel详解
  • 原文地址:https://www.cnblogs.com/hckblogs/p/9494312.html
Copyright © 2011-2022 走看看