java多线程模拟抢红包功能

java多线程模拟抢红包功能

今天有朋友问我一道面试题，有5个人抢5个红包，可重复抢，用多线程程序实现，实现方式有多种，分享一下我的思路：应用了阻塞队列的特性。

/**

* Created by zhanglinqiang on 2016/6/23.

*/

public class MyTest {

public static void main(String[] args) throws InterruptedException {

LinkedBlockingQueue luckyMoneys = new LinkedBlockingQueue<>();

List futureTasks = new ArrayList<>();

//准备抢红包

for (int i = 0; i < 5; i++) {

FutureTask

new Thread(futureTask,"name"+i).start();

futureTasks.add(futureTask);

}

Thread.sleep(5);//确保抢红包线程准备就绪

Random random = new Random(100);

//发5个红包

for (int i = 0; i < 5; i++) {

luckyMoneys.put(new LuckyMoney("红包"+i, random.nextInt(100)+1));

}

//等到红包抢完

while (!luckyMoneys.isEmpty()){

Thread.sleep(1);

}

//终止抢红包线程

for (FutureTask futureTask : futureTasks) {

futureTask.cancel(true);

}

}

}

class CatchLuckMoney implements Runnable {

public CatchLuckMoney(LinkedBlockingQueue luckyMoneys, String name) {

this.luckyMoneys = luckyMoneys;

this.name = name;

}

private LinkedBlockingQueue luckyMoneys;

private String name;

@Override

public void run() {

while (!Thread.currentThread().isInterrupted()) {

LuckyMoney redPackage = null;

try {

redPackage = luckyMoneys.take();

} catch (InterruptedException e) {

// e.printStackTrace();

break;

}

System.out.println(name + "抢到了-->" + redPackage);

luckyMoneys.remove(redPackage);

}

System.out.println("end>>>>>>>>>http://>>>>>>>>>>>>>>>>>>>"+Thread.currentThread().getName());

}

}

class LuckyMoney {

public LuckyMoney(String name, Integer money) {

this.name = name;

this.money = money;

}

private String name;

private Integer money;

@Override

public String toString() {

return "LuckyMoney{" +

"name='" + name + '\'' +

", money=" + money +

'}';

}

}

运行效果:

Connected to the target VM, address: '127.0.0.1:8869', transport: 'socket'

name3抢到了-->LuckyMoney{name='红包0', money=16}

name4抢到了-->LuckyMoney{name='红包3', money=89}

name0抢到了-->LuckyMoney{name='红包2', money=75}

name1抢到了-->LuckyMoney{name='红包1', money=51}

name3抢到了-->LuckyMoney{name='红包4', money=92}

end>>>>>>>>>>>>>>>>>>>>>>>>>>>>name0

end>>>>>>>>>>>>>>>>>>>>>>>>>>>>name4

end>>>>>>>>urjnowH>>>>>>>>>>>>>>>>>>>>name3

Disconnected from the target VM, address: '127.0.0.1:8869', transport: 'socket'

end>>>>>>>>>>>>>>>>>>>>>>>>>>>>name1

end>>>>>>>>>>>>>>>>>>>>>>>>>>>>name2

Process finished with exit code 0

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。