帮我写一段java高并发多线程抢购代码
时间: 2023-09-23 11:05:26 浏览: 128
### 回答1:
好的,以下是一段简单的 Java 高并发多线程抢购代码:
```
import java.util.concurrent.atomic.AtomicInteger;
public class ConcurrentPurchase implements Runnable {
private static final int TOTAL_COUNT = 100; // 总共要抢购的商品数量
private static AtomicInteger remainingCount = new AtomicInteger(TOTAL_COUNT); // 剩余商品数量,使用原子类保证线程安全
@Override
public void run() {
while (remainingCount.get() > ) { // 只要还有商品剩余,就继续抢购
int count = remainingCount.getAndDecrement(); // 使用原子类的减法操作,保证线程安全
if (count > ) {
System.out.println(Thread.currentThread().getName() + " 抢购成功,剩余商品数量:" + count);
} else {
System.out.println(Thread.currentThread().getName() + " 抢购失败,商品已经被抢完了");
}
}
}
public static void main(String[] args) {
ConcurrentPurchase purchase = new ConcurrentPurchase();
for (int i = 1; i <= 10; i++) { // 启动 10 个线程同时抢购
new Thread(purchase, "用户" + i).start();
}
}
}
```
这段代码实现了一个简单的抢购场景,使用了原子类保证了线程安全,可以同时启动多个线程进行抢购。
### 回答2:
下面是一个简单的Java高并发多线程抢购代码示例:
```java
import java.util.concurrent.atomic.AtomicInteger;
public class GrabTicket implements Runnable {
private static final AtomicInteger tickets = new AtomicInteger(10);
@Override
public void run() {
while (tickets.getAndDecrement() > 0) {
System.out.println(Thread.currentThread().getName() + " 抢到了一张票,剩余票数:" + tickets.get());
try {
Thread.sleep(100); // 模拟处理其他业务,这里设置为100毫秒
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
GrabTicket grabTicket = new GrabTicket();
for (int i = 1; i <= 5; i++) {
new Thread(grabTicket, "用户" + i).start();
}
}
}
```
上述代码创建了一个名为`GrabTicket`的类,实现了`Runnable`接口。通过`AtomicInteger`类型的`tickets`变量来表示剩余的票数,初始值为10。在`run`方法中,使用`tickets.getAndDecrement()`原子操作来判断并减少票数,当票数大于0时,表示成功抢到一张票,然后输出当前线程的名称和剩余票数。之后通过`Thread.sleep(100)`模拟处理其他业务的过程。
在`main`方法中,创建了5个线程去抢票,并启动这些线程。
运行这段代码可以看到,多个线程并发抢购票,成功抢到票的线程会输出相应的信息,并且剩余票数会随之减少。
### 回答3:
下面是一个简单的Java高并发多线程抢购代码示例:
```java
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class Seckill implements Runnable {
private static int inventory = 100; // 商品库存数量
private static int count = 0; // 成功抢购的数量
private static Lock lock = new ReentrantLock(); // 可重入锁
@Override
public void run() {
try {
Thread.sleep((long) (Math.random() * 2000)); // 模拟网络延迟
} catch (InterruptedException e) {
e.printStackTrace();
}
// 加锁保证只有一个线程能进入抢购逻辑
lock.lock();
if (inventory > 0) {
inventory--; // 商品库存减一
count++; // 成功抢购的数量加一
System.out.println(Thread.currentThread().getName() + " 抢购成功");
} else {
System.out.println(Thread.currentThread().getName() + " 抢购失败");
}
lock.unlock(); // 释放锁
}
public static void main(String[] args) {
// 创建多个线程进行抢购
for (int i = 0; i < 200; i++) {
Thread thread = new Thread(new Seckill());
thread.start();
}
try {
Thread.sleep(3000); // 等待所有抢购线程执行完毕
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("抢购结束,共成功抢购 " + count + " 个商品");
}
}
```
这段代码通过使用可重入锁保证只有一个线程能进入抢购逻辑,其他线程需要等待当前线程执行完毕。在`run()`方法中,首先模拟网络延迟,然后判断商品库存数量是否大于0,如果是,则进行抢购操作,即将商品库存减一并将成功抢购的数量加一;如果否,则抢购失败。最后,在主方法中创建多个线程进行抢购,并等待所有抢购线程执行完毕后输出成功抢购的商品数量。
阅读全文