我们设定有一个电影院，该电影院开张不久，在入口的旁边只设立了一个售票点A，顾客看电影，需要在售票点排队依次买票，买完票后在入口处检票进入电影院观影。
上面的描述用代码来实现，可以是这样的：
1、首先建立一个电影票的类：主要的属性有票的ID,哪个放映厅，哪一排哪一列，放映的电影名称，放映时间及票价。
/**
* 通过卖票程序读懂多线程--电影票的类
*
* @author zhuhuix
* @date 2020-05-12
*/
public class Ticket {
//id
private int ticketId;
//放映厅
private String room;
//行
private Integer row;
//列
private Integer col;
//电影名
private String filmName;
//价格
private BigDecimal price;
//放映时间
private LocalDateTime datetime;
private Ticket(){
}
public Ticket(int ticketId,String room, Integer row, Integer col, String filmName, BigDecimal price, LocalDateTime datetime) {
this.ticketId = ticketId;
this.room = room;
this.row = row;
this.col = col;
this.filmName = filmName;
this.price = price;
this.datetime = datetime;
}
public int getTicketId() {
return ticketId;
}
public void setTicketId(int ticketId) {
this.ticketId = ticketId;
}
public String getRoom() {
return room;
}
public void setRoom(String room) {
this.room = room;
}
public Integer getRow() {
return row;
}
public void setRow(Integer row) {
this.row = row;
}
public Integer getCol() {
return col;
}
public void setCol(Integer col) {
this.col = col;
}
public String getFilmName() {
return filmName;
}
public void setFilmName(String filmName) {
this.filmName = filmName;
}
public BigDecimal getPrice() {
return price;
}
public void setPrice(BigDecimal price) {
this.price = price;
}
public LocalDateTime getDatetime() {
return datetime;
}
public void setDatetime(LocalDateTime datetime) {
this.datetime = datetime;
}
@Override
public String toString() {
return "Ticket{" +
"ticketId=" + ticketId +
", room='" + room + '\'' +
", row=" + row +
", col=" + col +
", filmName='" + filmName + '\'' +
", price=" + price +
", datetime=" + datetime +
'}';
}
}2、其次建立一个顾客的类：主要的属性有票的ID,购买的电影票；成员方法有买票。
/**
* 通过卖票程序读懂多线程--顾客类
*
* @author zhuhuix
* @date 2020-05-12
*/
public class Customer {
//顾客id
private int customerId;
//购买的电影票
private Ticket ticket;
public Customer(int customerId) {
this.customerId = customerId;
}
//顾客买票
public void buyTicket(Ticket ticket) {
this.ticket = ticket;
}
public int getCustomerId() {
return customerId;
}
public void setCustomerId(int customerId) {
this.customerId = customerId;
}
public Ticket getTicket() {
return ticket;
}
public void setTicket(Ticket ticket) {
this.ticket = ticket;
}
@Override
public String toString() {
return "Customer{" +
"customerId=" + customerId +
", ticket=" + ticket.toString() +
'}';
}
}3、最后写一个主程序，生成电影票的列表，设定上门观影的顾客人数，依次买票，输出电影票购买的状态。
/**
* 通过卖票程序读懂多线程--单线程程序
*
* @author zhuhuix
* @date 2020-05-12
*/
public class TicketSingle {
private static final String ROOM = "中央放映厅";
private static final int ROW = 10;
private static final int COL = 20;
private static final String FILM_NAME = "战狼3";
private static final BigDecimal PRICE = BigDecimal.valueOf(30);
private static List<Ticket> tickets = new ArrayList<>();
private static final int CUSTOMER_COUNT = 250;
private static List<Customer> customers = new ArrayList<>(CUSTOMER_COUNT);
public static void main(String[] args) {
//中央放映厅总共有250个座位，2020-05-12 18:00 放映战狼3，售票价格为30元
int ticketId=1;
for (int row = 1; row <= ROW; row++) {
for (int col = 1; col <= COL; col++) {
Ticket ticket = new Ticket(ticketId++, ROOM, row, col,
FILM_NAME, PRICE,
LocalDateTime.of(2020, 5, 10, 18, 00));
tickets.add(ticket);
}
}
Iterator<Ticket> iterator = tickets.iterator();
while (iterator.hasNext()) {
System.out.println(iterator.next().toString());
}
//顾客到售票点进行随机买票
Collections.shuffle(tickets);
int index = 1;
while (tickets.size() > 0 && index <= CUSTOMER_COUNT) {
Ticket ticket = tickets.get(tickets.size() - 1);
Customer customer = new Customer(index);
customer.buyTicket(ticket);
customers.add(customer);
tickets.remove(ticket);
System.out.println(tickets.size() + "," + index);
System.out.println(index + "号顾客买到了"
+ "第" + customer.getTicket().getRow() + "行，第" + customer.getTicket().getCol() + "列的票");
index++;
try {
TimeUnit.MILLISECONDS.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("电影票出售情况如下：");
//剩余票的状态
System.out.println("剩余票数：" + tickets.size());
Iterator<Ticket> ticketIterator = tickets.iterator();
while (ticketIterator.hasNext()) {
System.out.println(ticketIterator.next().toString());
}
//顾客购买情况
System.out.println("买到票的人数：" + customers.size());
Iterator<Customer> customerIterator = customers.iterator();
while (customerIterator.hasNext()) {
System.out.println(customerIterator.next().toString());
}
System.out.println("未买到票的人数：" +(CUSTOMER_COUNT- customers.size()));
}
}主程序的输出情况是这样的：
一切井然有序，程序也运行得很好，那我们继续往 下看，由于观影顾客人数的增加，电影院对放映厅做了改造：
也就说原来只有一个窗口排队单通道执行的程序变了，要允许原来的售票点与新增的售票点，同时进行卖票了。
我们先简单的在单线程的程序上做个多线程的改造：建立一个多线程的类，重写run方法，将顾客买票的过程移至run方法中，在主程中设立”售票点A“，”售票点B“，”售票点C“三个线程让其同时运行，对了，别忘了把ArrayList这个数据结构也改成Vector。改造后的程序是这样的：
/**
* 通过卖票程序读懂多线程--多线程
*
* @author zhuhuix
* @date 2020-05-12
*/
public class TicketThread extends Thread {
private static final String ROOM = "中央放映厅";
private static final int ROW = 20;
private static final int COL = 30;
private static final String FILM_NAME = "战狼3";
private static final BigDecimal PRICE = BigDecimal.valueOf(30);
private static List<Ticket> tickets = new Vector<>();
private static final int CUSTOMER_COUNT = 800;
private static int customerId = 1;
private static List<Customer> customers = new Vector<>(CUSTOMER_COUNT);
TicketThread(String name) {
super(name);
}
@Override
public void run() {
while (tickets.size() > 0 && customerId <= CUSTOMER_COUNT) {
Ticket ticket = tickets.get(tickets.size() - 1);
ticket.setWindow(Thread.currentThread().getName());
Customer customer = new Customer(customerId);
customer.buyTicket(ticket);
customers.add(customer);
tickets.remove(ticket);
System.out.println(tickets.size() + "," + customerId);
System.out.println(Thread.currentThread().getName() + ":" + customerId + "号顾客买到了"
+ "第" + customer.getTicket().getRow() + "行，第" + customer.getTicket().getCol() + "列的票");
customerId++;
try {
TimeUnit.MILLISECONDS.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) throws InterruptedException {
//中央放映厅总共有250个座位，2020-05-12 18:00 放映战狼3，售票价格为30元
int ticketId = 1;
for (int row = 1; row <= ROW; row++) {
for (int col = 1; col <= COL; col++) {
Ticket ticket = new Ticket(ticketId++, ROOM, row, col,
FILM_NAME, PRICE,
LocalDateTime.of(2020, 5, 10, 18, 00));
tickets.add(ticket);
}
}
Iterator<Ticket> iterator = tickets.iterator();
while (iterator.hasNext()) {
System.out.println(iterator.next().toString());
}
//顾客到售票点进行随机买票
Collections.shuffle(tickets);
TicketThread ticketThreadA = new TicketThread("售票点A");
TicketThread ticketThreadB = new TicketThread("售票点B");
TicketThread ticketThreadC = new TicketThread("售票点C");
ticketThreadA.start();
ticketThreadB.start();
ticketThreadC.start();
ticketThreadA.join();
ticketThreadB.join();
ticketThreadC.join();
System.out.println("电影票出售情况如下：");
//剩余票的状态
System.out.println("总共票数:" + ROW * COL + ",剩余票数：" + tickets.size());
Iterator<Ticket> ticketIterator = tickets.iterator();
while (ticketIterator.hasNext()) {
System.out.println(ticketIterator.next().toString());
}
//顾客购买情况
System.out.println("买到票的人数：" + customers.size());
Iterator<Customer> customerIterator = customers.iterator();
while (customerIterator.hasNext()) {
System.out.println(customerIterator.next().toString());
}
System.out.println("未买到票的人数：" + (CUSTOMER_COUNT - customers.size()));
}
}运行一下：总共只有600张票，买到票的人有614人？那进了电影院顾客肯定得投诉。
我们分析一下：
电影票总共只有600张，三个窗口同时卖这600张票，电影票是个共享的池子，在多线程术语上称为”共享资源“或”临界资源“，每个线程访问这些资源时，要保证”同步“：售票点A要卖第10排第9列的座位时，当且仅当同一时刻只有售票点A才能访问这个座位对应的电影票，也就是所谓的不能一票多卖。
那多线程如何保证同步？通过加锁！！加锁是用来控制多个线程访问共享资源的方式，一般来说，一个锁能够防止多个线程同时访问共享资源。
为了可以简单地说明加锁可以保证多线程同步，在下面的例子中仅实现对电影票共享池进行加锁。
/**
* 通过卖票程序读懂多线程--多线程
*
* @author zhuhuix
* @date 2020-05-12
*/
public class TicketThread extends Thread {
private static final String ROOM = "中央放映厅";
private static final int ROW = 20;
private static final int COL = 30;
private static final String FILM_NAME = "战狼3";
private static final BigDecimal PRICE = BigDecimal.valueOf(30);
private volatile static List<Ticket> tickets = new Vector<>();
private static final int CUSTOMER_COUNT = 800;
private static int customerId = 1;
private volatile static List<Customer> customers = new Vector<>(CUSTOMER_COUNT);
TicketThread(String name) {
super(name);
}
@Override
public void run() {
while (tickets.size() > 0 && customerId <= CUSTOMER_COUNT) {
synchronized (TicketThread.class) {
//线程内两次判断，防止tickets 数组溢出
if (tickets.size()>0) {
Ticket ticket = tickets.get(tickets.size() - 1);
ticket.setWindow(Thread.currentThread().getName());
Customer customer = new Customer(customerId);
customer.buyTicket(ticket);
customers.add(customer);
tickets.remove(ticket);
System.out.println(tickets.size() + "," + customerId);
System.out.println(Thread.currentThread().getName() + ":" + customerId + "号顾客买到了"
+ "第" + customer.getTicket().getRow() + "行，第" + customer.getTicket().getCol() + "列的票");
customerId++;
try {
TimeUnit.MILLISECONDS.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
public static void main(String[] args) throws InterruptedException {
//中央放映厅总共有250个座位，2020-05-12 18:00 放映战狼3，售票价格为30元
int ticketId = 1;
for (int row = 1; row <= ROW; row++) {
for (int col = 1; col <= COL; col++) {
Ticket ticket = new Ticket(ticketId++, ROOM, row, col,
FILM_NAME, PRICE,
LocalDateTime.of(2020, 5, 10, 18, 00));
tickets.add(ticket);
}
}
Iterator<Ticket> iterator = tickets.iterator();
while (iterator.hasNext()) {
System.out.println(iterator.next().toString());
}
//顾客到售票点进行随机买票
Collections.shuffle(tickets);
TicketThread ticketThreadA = new TicketThread("售票点A");
TicketThread ticketThreadB = new TicketThread("售票点B");
TicketThread ticketThreadC = new TicketThread("售票点C");
ticketThreadA.start();
ticketThreadB.start();
ticketThreadC.start();
ticketThreadA.join();
ticketThreadB.join();
ticketThreadC.join();
System.out.println("电影票出售情况如下：");
//剩余票的状态
System.out.println("总共票数:" + ROW * COL + ",剩余票数：" + tickets.size());
Iterator<Ticket> ticketIterator = tickets.iterator();
while (ticketIterator.hasNext()) {
System.out.println(ticketIterator.next().toString());
}
//顾客购买情况
System.out.println("买到票的人数：" + customers.size());
Iterator<Customer> customerIterator = customers.iterator();
while (customerIterator.hasNext()) {
System.out.println(customerIterator.next().toString());
}
System.out.println("未买到票的人数：" + (CUSTOMER_COUNT - customers.size()));
}
}运行情况如下：
票不超卖了：
每个窗口也实现了同步并发卖票：
同步的代码主要的改变来自于：
1、将卖票的过程用synchronized修饰，实现锁的互斥，具体可以参考java多线程：
https://blog.csdn.net/jpgzhu/article/details/105967947
synchronized (TicketThread.class) {
Ticket ticket = tickets.get(tickets.size() - 1);
ticket.setWindow(Thread.currentThread().getName());
Customer customer = new Customer(customerId);
customer.buyTicket(ticket);
customers.add(customer);
tickets.remove(ticket);
System.out.println(tickets.size() + "," + customerId);
System.out.println(Thread.currentThread().getName() + ":" + customerId + "号顾客买到了"
+ "第" + customer.getTicket().getRow() + "行，第" + customer.getTicket().getCol() + "列的票");
customerId++;
try {
TimeUnit.MILLISECONDS.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}2、将共享资源用volatile 修饰，实现线程访问的可视化，具体可以参考上文链接。
private volatile static List<Ticket> tickets = new Vector<>();
private volatile static List<Customer> customers = new Vector<>(CUSTOMER_COUNT);程序所有的表达，归根到底都是逻辑问题。而逻辑的核心是清晰高效地思考问题。对于多线程的理解，大家一定要起手来写一些例程，融汇贯通才能体会到真谛，才能真正应用到工作实践中去。
本文由哈喽比特于4年以前收录，如有侵权请联系我们。
文章来源：https://mp.weixin.qq.com/s/QWdT6SXlrwmLYqCtuRRMZQ
京东创始人刘强东和其妻子章泽天最近成为了互联网舆论关注的焦点。有关他们“移民美国”和在美国购买豪宅的传言在互联网上广泛传播。然而，京东官方通过微博发言人发布的消息澄清了这些传言，称这些言论纯属虚假信息和蓄意捏造。
日前，据博主“@超能数码君老周”爆料，国内三大运营商中国移动、中国电信和中国联通预计将集体采购百万台规模的华为Mate60系列手机。
据报道，荷兰半导体设备公司ASML正看到美国对华遏制政策的负面影响。阿斯麦（ASML）CEO彼得·温宁克在一档电视节目中分享了他对中国大陆问题以及该公司面临的出口管制和保护主义的看法。彼得曾在多个场合表达了他对出口管制以及中荷经济关系的担忧。
今年早些时候，抖音悄然上线了一款名为“青桃”的 App，Slogan 为“看见你的热爱”，根据应用介绍可知，“青桃”是一个属于年轻人的兴趣知识视频平台，由抖音官方出品的中长视频关联版本，整体风格有些类似B站。
日前，威马汽车首席数据官梅松林转发了一份“世界各国地区拥车率排行榜”，同时，他发文表示：中国汽车普及率低于非洲国家尼日利亚，每百户家庭仅17户有车。意大利世界排名第一，每十户中九户有车。
近日，一项新的研究发现，维生素 C 和 E 等抗氧化剂会激活一种机制，刺激癌症肿瘤中新血管的生长，帮助它们生长和扩散。
据媒体援引消息人士报道，苹果公司正在测试使用3D打印技术来生产其智能手表的钢质底盘。消息传出后，3D系统一度大涨超10%，不过截至周三收盘，该股涨幅回落至2%以内。
9月2日，坐拥千万粉丝的网红主播“秀才”账号被封禁，在社交媒体平台上引发热议。平台相关负责人表示，“秀才”账号违反平台相关规定，已封禁。据知情人士透露，秀才近期被举报存在违法行为，这可能是他被封禁的部分原因。据悉，“秀才”年龄39岁，是安徽省亳州市蒙城县人，抖音网红，粉丝数量超1200万。他曾被称为“中老年...
9月3日消息，亚马逊的一些股东，包括持有该公司股票的一家养老基金，日前对亚马逊、其创始人贝索斯和其董事会提起诉讼，指控他们在为 Project Kuiper 卫星星座项目购买发射服务时“违反了信义义务”。
据消息，为推广自家应用，苹果现推出了一个名为“Apps by Apple”的网站，展示了苹果为旗下产品（如 iPhone、iPad、Apple Watch、Mac 和 Apple TV）开发的各种应用程序。
特斯拉本周在美国大幅下调Model S和X售价，引发了该公司一些最坚定支持者的不满。知名特斯拉多头、未来基金（Future Fund）管理合伙人加里·布莱克发帖称，降价是一种“短期麻醉剂”，会让潜在客户等待进一步降价。
据外媒9月2日报道，荷兰半导体设备制造商阿斯麦称，尽管荷兰政府颁布的半导体设备出口管制新规9月正式生效，但该公司已获得在2023年底以前向中国运送受限制芯片制造机器的许可。
近日，根据美国证券交易委员会的文件显示，苹果卫星服务提供商 Globalstar 近期向马斯克旗下的 SpaceX 支付 6400 万美元（约 4.65 亿元人民币）。用于在 2023-2025 年期间，发射卫星，进一步扩展苹果 iPhone 系列的 SOS 卫星服务。
据报道，马斯克旗下社交平台𝕏（推特）日前调整了隐私政策，允许 𝕏 使用用户发布的信息来训练其人工智能（AI）模型。新的隐私政策将于 9 月 29 日生效。新政策规定，𝕏可能会使用所收集到的平台信息和公开可用的信息，来帮助训练 𝕏 的机器学习或人工智能模型。
9月2日，荣耀CEO赵明在采访中谈及华为手机回归时表示，替老同事们高兴，觉得手机行业，由于华为的回归，让竞争充满了更多的可能性和更多的魅力，对行业来说也是件好事。
《自然》30日发表的一篇论文报道了一个名为Swift的人工智能（AI）系统，该系统驾驶无人机的能力可在真实世界中一对一冠军赛里战胜人类对手。
近日，非营利组织纽约真菌学会（NYMS）发出警告，表示亚马逊为代表的电商平台上，充斥着各种AI生成的蘑菇觅食科普书籍，其中存在诸多错误。
社交媒体平台𝕏（原推特）新隐私政策提到：“在您同意的情况下，我们可能出于安全、安保和身份识别目的收集和使用您的生物识别信息。”
2023年德国柏林消费电子展上，各大企业都带来了最新的理念和产品，而高端化、本土化的中国产品正在不断吸引欧洲等国际市场的目光。
罗永浩日前在直播中吐槽苹果即将推出的 iPhone 新品，具体内容为：“以我对我‘子公司’的了解，我认为 iPhone 15 跟 iPhone 14 不会有什么区别的，除了序（列）号变了，这个‘不要脸’的东西，这个‘臭厨子’。
