九乡新闻网铭记中国二战贡献:Java:多线程模拟多站点售票过程
来源：百度文库 编辑：九乡新闻网 时间：2024/04/29 08:58:21
这是一个在并发状态下对共享资源的多线程访问。这些访问必须是互斥的进行，因为涉及到对资源的修改。假设现在销售火车票。目的地有3个，分别是北京，天津和上海。使用一个枚举类型表示。
Destation.java
package com.zj.tickets;
public enum Destation {
BEIJING, SHANGHAI, TIANJING
}
下面设计车票类，final int original表示车票基数；int current表示当前还有多少张票；Destation destation表示目的地，它必须从上面的枚举型中取出其一。
Ticket.java
package com.zj.tickets;
public class Ticket {
private final int original;
private int current;
private final Destation destation;
public Ticket(int nums, Destation where) {
current = original = nums;
destation = where;
}
public int degress() {
return --current;
}
public int original() {
return original;
}
public boolean soldout() {
return current <= 0;
}
public Destation getDestation() {
return destation;
}
public int getCurrent() {
return current;
}
}
下面设计售票厅类，Map tickets表示目前可销售的车票种类，它通过一个static块初始化。Map records是当前售票厅的火车票销售情况。Listoffices表示当前可工作的所有售票厅，每个售票厅是一个线程。int ticketsSold表示当前售票厅售出的火车票总数。int id表示当前售票厅编号。
每个线程都会模拟客户买票、工作人员查询数据库和售票交易过程。
模拟的数据为，当前发往北京、上海和天津的火车票各5张；每个售票厅交易5次（无论交易成功或失败）后关闭。
BookingOffice.java
package com.zj.tickets;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.concurrent.TimeUnit;
public class BookingOffice implements Runnable {
private static Map tickets = new HashMap();
private Map records;
private static List offices = new ArrayList();
private int ticketsSold = 0;
private final int id;
// now today's tickets for sell:
static {
tickets.put(Destation.BEIJING, new Ticket(5, Destation.BEIJING));
tickets.put(Destation.SHANGHAI, new Ticket(5, Destation.SHANGHAI));
tickets.put(Destation.TIANJING, new Ticket(5, Destation.TIANJING));
}
public BookingOffice(int id) {
this.id = id;
offices.add(this);
resetRecords();
}
private void resetRecords() {
records = new HashMap();
}
private void addRecords(Destation d) {
Integer freq = records.get(d);
records.put(d, freq == null ? 1 : freq + 1);
}
public void run() {
int transaction = 5;
while (transaction-- > 0) {
// simulate a customer's coming:
Destation d = Destation.values()[new Random().nextInt(Destation
.values().length)];
print(this + "i want a ticket for " + d);
// simulate the officer's checking:
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
// simulate the transaction:
Ticket wanted = tickets.get(d);
synchronized (wanted) {
if (!wanted.soldout()) {
print(this + "sold a ticket for " + d);
wanted.degress();
addRecords(d);
++ticketsSold;
print(this + "" + d + " tickets still have "
+ wanted.getCurrent());
} else
print(this + "tickets for " + d + " have been sold out.");
}
}
print(this + "closed");
print(this + "totally sold tickets:" + ticketsSold + ",sell records:"
+ records);
}
public synchronized int getValue() {
return ticketsSold;
}
public String toString() {
return "";
}
static void print(String s) {
System.out.println(s);
}
}
模拟售票过程如下，启动5个售票厅。
Sell.java
package com.zj.tickets;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Sell {
public static void main(String[] args) throws Exception {
ExecutorService exec = Executors.newCachedThreadPool();
for (int i = 0; i < 5; i++)
exec.execute(new BookingOffice(i));
exec.shutdown();
}
}
结果：
i want aticket for BEIJING
i want aticket for SHANGHAI
i want aticket for TIANJING
i want aticket for SHANGHAI
i want aticket for SHANGHAI
sold a ticketfor BEIJING
BEIJING tickets stillhave 4
i want aticket for TIANJING
sold a ticketfor SHANGHAI
SHANGHAI tickets stillhave 4
i want aticket for SHANGHAI
sold a ticketfor TIANJING
TIANJINGtickets still have 4
i want aticket for BEIJING
sold a ticketfor SHANGHAI
SHANGHAI tickets stillhave 3
i want aticket for TIANJING
sold a ticketfor SHANGHAI
SHANGHAI tickets stillhave 2
i want aticket for BEIJING
sold a ticketfor BEIJING
BEIJING tickets stillhave 3
i want aticket for SHANGHAI
sold a ticketfor TIANJING
TIANJINGtickets still have 3
i want aticket for TIANJING
sold a ticketfor BEIJING
BEIJING tickets stillhave 2
i want aticket for BEIJING
sold a ticketfor SHANGHAI
SHANGHAI tickets stillhave 1
i want aticket for SHANGHAI
sold a ticketfor TIANJING
TIANJINGtickets still have 2
i want aticket for SHANGHAI
sold a ticketfor SHANGHAI
SHANGHAI tickets stillhave 0
i want aticket for BEIJING
sold a ticketfor TIANJING
TIANJINGtickets still have 1
i want aticket for BEIJING
sold a ticketfor BEIJING
BEIJING tickets stillhave 1
i want aticket for SHANGHAI
tickets for SHANGHAI have been soldout.
i want aticket for SHANGHAI
tickets for SHANGHAI have been soldout.
i want aticket for SHANGHAI
sold a ticketfor BEIJING
BEIJING tickets stillhave 0
i want aticket for BEIJING
tickets for BEIJING have been soldout.
i want aticket for BEIJING
tickets for SHANGHAI have been soldout.
i want aticket for SHANGHAI
tickets for SHANGHAI have been soldout.
i want aticket for BEIJING
tickets for SHANGHAI have been soldout.
i want aticket for SHANGHAI
tickets for BEIJING have been soldout.
closed
totally soldtickets:4,sell records:{BEIJING=2, SHANGHAI=2}
tickets for BEIJING have been soldout.
closed
totally soldtickets:3,sell records:{TIANJING=2, SHANGHAI=1}
tickets for SHANGHAI have been soldout.
closed
totally soldtickets:3,sell records:{BEIJING=2,TIANJING=1}
tickets for BEIJING have been soldout.
closed
totally soldtickets:2,sell records:{SHANGHAI=2}
tickets for SHANGHAI have been soldout.
closed
totally soldtickets:2,sell records:{BEIJING=1,TIANJING=1}
本文出自 “子 孑” 博客，请务必保留此出处http://zhangjunhd.blog.51cto.com/113473/70767
Destation.java
package com.zj.tickets;
public enum Destation {
BEIJING, SHANGHAI, TIANJING
}
下面设计车票类，final int original表示车票基数；int current表示当前还有多少张票；Destation destation表示目的地，它必须从上面的枚举型中取出其一。
Ticket.java
package com.zj.tickets;
public class Ticket {
private final int original;
private int current;
private final Destation destation;
public Ticket(int nums, Destation where) {
current = original = nums;
destation = where;
}
public int degress() {
return --current;
}
public int original() {
return original;
}
public boolean soldout() {
return current <= 0;
}
public Destation getDestation() {
return destation;
}
public int getCurrent() {
return current;
}
}
下面设计售票厅类，Map
每个线程都会模拟客户买票、工作人员查询数据库和售票交易过程。
模拟的数据为，当前发往北京、上海和天津的火车票各5张；每个售票厅交易5次（无论交易成功或失败）后关闭。
BookingOffice.java
package com.zj.tickets;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.concurrent.TimeUnit;
public class BookingOffice implements Runnable {
private static Map
private Map
private static List
private int ticketsSold = 0;
private final int id;
// now today's tickets for sell:
static {
tickets.put(Destation.BEIJING, new Ticket(5, Destation.BEIJING));
tickets.put(Destation.SHANGHAI, new Ticket(5, Destation.SHANGHAI));
tickets.put(Destation.TIANJING, new Ticket(5, Destation.TIANJING));
}
public BookingOffice(int id) {
this.id = id;
offices.add(this);
resetRecords();
}
private void resetRecords() {
records = new HashMap
}
private void addRecords(Destation d) {
Integer freq = records.get(d);
records.put(d, freq == null ? 1 : freq + 1);
}
public void run() {
int transaction = 5;
while (transaction-- > 0) {
// simulate a customer's coming:
Destation d = Destation.values()[new Random().nextInt(Destation
.values().length)];
print(this + "i want a ticket for " + d);
// simulate the officer's checking:
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
// simulate the transaction:
Ticket wanted = tickets.get(d);
synchronized (wanted) {
if (!wanted.soldout()) {
print(this + "sold a ticket for " + d);
wanted.degress();
addRecords(d);
++ticketsSold;
print(this + "" + d + " tickets still have "
+ wanted.getCurrent());
} else
print(this + "tickets for " + d + " have been sold out.");
}
}
print(this + "closed");
print(this + "totally sold tickets:" + ticketsSold + ",sell records:"
+ records);
}
public synchronized int getValue() {
return ticketsSold;
}
public String toString() {
return "
}
static void print(String s) {
System.out.println(s);
}
}
模拟售票过程如下，启动5个售票厅。
Sell.java
package com.zj.tickets;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Sell {
public static void main(String[] args) throws Exception {
ExecutorService exec = Executors.newCachedThreadPool();
for (int i = 0; i < 5; i++)
exec.execute(new BookingOffice(i));
exec.shutdown();
}
}
结果：
本文出自 “子 孑” 博客，请务必保留此出处http://zhangjunhd.blog.51cto.com/113473/70767
Java:多线程模拟多站点售票过程
Java多线程程序设计解析
Java多线程编程总结
Java多线程编程总结
Java多线程编程详解
编写多线程的 Java 应用程序
java.util.concurrent 多线程框架
JAVA多线程同步wait、notify、synchronized/
Java多线程程序设计详细解析1
Java多线程 Reactor模式和NIO
Java Threads 多线程10分钟参考手册
java 实现多线程复制功能，支持中断后继续。
多线程
Oracle存储过程实现多线程对表数据的抽取
Oracle存储过程实现多线程对表数据的抽取
linux下编程学习----- 远程过程调用(rpc) - shake863 - Java...
解析Java类和对象的初始化过程
java
多线程调试
多线程Demo
铁路部门瞒报路段塌方继续售票 多车次乘客被困
铁路部门瞒报路段塌方继续售票 多车次乘客被困
铁路部门瞒报路段塌方继续售票 多车次乘客被困
图解JAVA-JAR/JAD格式游戏软件在手机上 的详细安装过程