package com.sgz.demo;
/**
* 日期:2022/8/28 - 9:13
* 需求:基本的卖票例子
* 真正的多线程开发,公司中的开发
* 线程就是一个单独的资源类,没有任何附属的操作
* 1、属性,方法
*/
public class SaleTicketDemo01 {
public static void main(String[] args) {
// 并发,多个线程操作同一个资源类,把资源类丢入线程
Ticket ticket = new Ticket();
// 函数式接口,Lambda表达式 ( 参数 ) -> { 代码 }
new Thread(() -> {
for (int i = 1; i < 40; i++) {
ticket.sale();
}
}, "A").start();
new Thread(() -> {
for (int i = 1; i < 40; i++) {
ticket.sale();
}
}, "B").start();
new Thread(() -> {
for (int i = 1; i < 40; i++) {
ticket.sale();
}
}, "C").start();
}
}
// 资源类 OOP(面向对象)
class Ticket {
// 属性、方法,共30张票
private int number = 30;
// 卖票的方式
// synchronized:本质是排队,是个锁
public synchronized void sale() {
if (number > 0) {
System.out.println(Thread.currentThread().getName() + "卖出了" + (number--) + "票,剩余:" + number);
}
}
}



package com.sgz.demo;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* 日期:2022/8/28 - 9:13
* 需求:基本的卖票例子
* 真正的多线程开发,公司中的开发
* 线程就是一个单独的资源类,没有任何附属的操作
* 1、属性,方法
*/
public class SaleTicketDemo02 {
public static void main(String[] args) {
// 并发,多个线程操作同一个资源类,把资源类丢入线程
Ticket2 ticket = new Ticket2();
// 函数式接口,Lambda表达式 ( 参数 ) -> { 代码 }
new Thread(() -> {for (int i = 1; i < 40; i++) ticket.sale();}, "A").start();
new Thread(() -> {for (int i = 1; i < 40; i++) ticket.sale();}, "B").start();
new Thread(() -> {for (int i = 1; i < 40; i++) ticket.sale();}, "C").start();
}
}
// Lock三部曲
// 1、new ReentrantLock(); new对象
// 2、lock.lock(); //加锁
// 3、lock.unlock(); // 解锁
// 资源类 OOP(面向对象)
class Ticket2 {
// 属性、方法
private int number = 30;
Lock lock = new ReentrantLock();
// 卖票的方式
public void sale() {
lock.lock(); // 加锁
try {
if (number > 0) {
System.out.println(Thread.currentThread().getName() + "卖出了" + (number--) + "票,剩余:" + number);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock(); // 解锁
}
}
}
基本使用步骤: