写在前边: 在Java服务端中,会常常遇到并发的场景,以下我使用两个售票的案例实现传统的Lock锁与synchronized加锁解决线程安全问题。
本章代码:Gitee: juc.demo
一、Lock锁
ReentrantLock 类: 可重用锁(公平锁|非公平锁)ReentrantReadWriteLock.ReadLock :读锁ReentrantReadWriteLock.WriteLock :写锁
二、锁的底层
锁的底层有公平锁和非公平锁。其中:
- 公平锁 :十分公平,不能插队。
- 非公平锁 :十分不公平,可以插队。(默认非公平锁)
三、案例
案例一:传统的synchronized实现
public class SaleTicketDemo01 {
public static void main(String[] args) {
Ticket ticket = new Ticket();
new Thread(()->{
for (int i = 0; i < 60; i++) {
ticket.sale();
}
},"AA").start();
new Thread(()->{
for (int i = 0; i < 60; i++) {
ticket.sale();
}
},"BB").start();
new Thread(() -> {
for (int i = 0; i < 60; i++) {
ticket.sale();
}
}, "CC").start();
}
static class Ticket{
private int num = 50;
public synchronized void sale(){
if (num > 0){
System.out.println(Thread.currentThread().getName()+"卖出了"+(num--)+"票,剩余:"+num);
}
}
}
}
案例二:Lock锁的实现
public class SaleTicketDemo02 {
public static void main(String[] args) {
Ticket2 ticket = new Ticket2();
new Thread(()->{ for (int i = 0; i < 60; i++) ticket.sale(); },"AA").start();
new Thread(()->{ for (int i = 0; i < 60; i++) ticket.sale(); },"BB").start();
new Thread(()->{ for (int i = 0; i < 60; i++) ticket.sale(); },"CC").start();
}
static class Ticket2{
private int num = 50;
public void sale(){
Lock lock = new ReentrantLock();
lock.lock();
try {
if (num > 0){
System.out.println(Thread.currentThread().getName()+"卖出了"+(num--)+"票,剩余:"+num);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}
}
四、Lock锁和synchronized的区别
snchronized 是内置Java关键字;Lock 是一个Java类。synchronized 无法判断获取锁的状态;Lock 可以判断是否获取到了锁。(boolean b = lock.tryLock();)synchronized 会自动释放锁;Lock 必须要手动释放锁,如果不释放锁,死锁。synchronized 线程1获得锁阻塞时,线程2会一直等待下去;Lock锁线程1获得锁阻塞时,线程2等待足够长的时间后中断等待,去做其他的事。synchronized 可重入锁:不可以中断的,非公平;Lock可重入锁:可以判断锁,非公平(可以自己设置)。 lock.lockInterruptibly() ;方法:当两个线程同时通过该方法想获取某个锁时,假若此时线程A获取到了锁,而线程B只有在等待,那么对线程B调用threadB.interrupt() 方法能够中断线程B的等待过程。synchronized 适合锁少量的代码同步问题; Lock适合锁大量的同步代码。
本文文献: Bilibili狂神说
|