java设计:现有一个在线售票系统,总共有200张票,假设4个线程同时订票,网络传输延时为5毫秒,试编写程序模拟12306的售票过程。 进阶设计:试考虑同步机制。
时间: 2024-02-20 18:01:30 浏览: 180
以下是一个Java程序,模拟了一个在线售票系统,使用了线程和锁来保证线程安全。程序中设置了200张票,4个线程不断地随机选择一张未售出的票进行购买,直到所有票都售出为止。在每次购买时,程序会模拟网络延迟,以增加并发量和模拟实际情况。
```java
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class OnlineTicketSystem {
private int numTickets;
private List<Integer> tickets;
private Lock lock;
public OnlineTicketSystem(int numTickets) {
this.numTickets = numTickets;
this.tickets = new ArrayList<>();
for (int i = 1; i <= numTickets; i++) {
tickets.add(i);
}
this.lock = new ReentrantLock();
}
public void buyTicket(int threadId) {
Random random = new Random();
while (true) {
lock.lock();
if (tickets.size() == 0) {
lock.unlock();
break;
}
int ticketIndex = random.nextInt(tickets.size());
int ticket = tickets.get(ticketIndex);
tickets.remove(ticketIndex);
lock.unlock();
System.out.println("Thread " + threadId + " bought ticket " + ticket);
try {
Thread.sleep(5);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
OnlineTicketSystem ticketSystem = new OnlineTicketSystem(200);
List<Thread> threads = new ArrayList<>();
for (int i = 0; i < 4; i++) {
Thread thread = new Thread(() -> ticketSystem.buyTicket(i));
thread.start();
threads.add(thread);
}
for (Thread thread : threads) {
try {
thread.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
```
在程序中,`OnlineTicketSystem` 类表示在线售票系统,它包括了票数和票的列表。当一个线程购买一张票时,它会先获得锁,然后随机选择一张未售出的票进行购买,购买成功后将票从列表中删除,最后释放锁。使用锁可以保证多个线程不会同时购买同一张票,从而保证线程安全。
程序中使用了 `Thread.sleep(5)` 来模拟网络延迟,实际应用中可以根据实际情况调整延迟时间。
阅读全文