java通过lock实现同步锁

这里我们是一个卖票的演示代码

其实 同步锁 远不止一个synchronized
它本身有一个 加上锁 和释放锁的过程
为了 让我们更好的理解这个过程 JDK5之后 为我们提供了一个单独的锁工具 lock

lock是一个接口 他提供了 synchronized 方法 和 更广泛的语句操作

lock方法 获得锁
unlock方法 释放锁

ReentrantLock 类 可以实例化lock接口

然后我们就来写代码演示一下

在一个包下创建两个类

customException 线程类
参考代码如下

public class customException implements Runnable {
    private static int tickets = 100;

    public void run () {
        while (true){
            if(tickets > 0) {
                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName()+"正在出售第"+tickets+"张票");
                tickets--;
            }
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

这里 我们定义了一个买票的线程
tickets 代表了票数 总共100张
然后我们测试类 text 参考代码如下

public class text {
    public static void main(String args[]) {
        Runnable Runnable = new customException();
        Thread m1 = new Thread(Runnable,"客服");
        Thread m2 = new Thread(Runnable,"黄牛");
        Thread m3 = new Thread(Runnable,"导爷");
        m1.start();
        m2.start();
        m3.start();
    }
}
1
2
3
4
5
6
7
8
9
10
11

但我们这里 没有用同步锁 也没有同步方法 大概率是要出问题的

我们运行代码如下

这里 可以看到 因为没有同步锁 他就出现了线程的常见问题

这里 我们通过 lock 实现一下这个锁的功能
将customException类代码修改如下

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class customException implements Runnable {
    private static int tickets = 100;
    private Lock lock = new ReentrantLock();

    public void run () {
        while (true){
            try {
                lock.lock();
                if (tickets > 0) {
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
                    tickets--;
                }
            } finally {
                lock.unlock();
            }
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

这里 我们引入了 Lock接口 和 ReentrantLock类 然后通过 ReentrantLock实例化一个Lock对象 叫lock

然后 我们在代码开始处执行lock
结束区域 释放锁执行unlock
我们运行代码 效果如下

也是没有任何问题