java并發(fā)編程學(xué)習(xí)18--最迷你的搶紅包

caohaoyu 發(fā)布于2019-08-15 14:34 / 2610人閱讀

摘要：業(yè)務(wù)分析要完成搶紅包的功能重點(diǎn)有兩個(gè)多線程并發(fā)修改數(shù)據(jù)紅包現(xiàn)金分配算法類(lèi)設(shè)計(jì)用戶(hù)對(duì)象包含用戶(hù)名稱(chēng)，所搶到的金額，最后的提示文言字段搶紅包的用戶(hù)用戶(hù)昵稱(chēng)用戶(hù)搶到的金額用戶(hù)獲得系統(tǒng)提示文言并發(fā)訪問(wèn)的共享紅包對(duì)象這個(gè)對(duì)象包含了預(yù)分配的所有小紅包并

【業(yè)務(wù)分析

要完成搶紅包的功能重點(diǎn)有兩個(gè)：

多線程并發(fā)修改數(shù)據(jù)

紅包現(xiàn)金分配算法

【類(lèi)設(shè)計(jì)

用戶(hù)對(duì)象：包含用戶(hù)名稱(chēng)，所搶到的金額，最后的提示文言字段

package com.xz.core;

/**
 * 搶紅包的用戶(hù)
 * @author ibm
 */
public class User {

    /**
     * 用戶(hù)昵稱(chēng)
     */
    private String name;
    /**
     * 用戶(hù)搶到的金額
     */
    private int money;
    /**
     * 用戶(hù)獲得系統(tǒng)提示文言
     */
    private String info;

    public User(String name, int money, String info) {
        this.name = name;
        this.money = money;
        this.info = info;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public double getMoney() {
        return money;
    }

    public void setMoney(int money) {
        this.money = money;
    }

    public String getInfo() {
        return info;
    }

    public void setInfo(String info) {
        this.info = info;
    }

}

并發(fā)訪問(wèn)的共享紅包對(duì)象：這個(gè)對(duì)象包含了預(yù)分配的所有小紅包并提供并發(fā)控制，用戶(hù)線程只能通過(guò)這個(gè)類(lèi)獲得紅包

package com.xz.core;

import java.util.List;

public class Moneys {

    /**
     * 預(yù)分配的紅包金額
     */
    List moneys;

    Moneys(List moneys){
        this.moneys = moneys;
    }

    /**
     * 獲得紅包，如果一個(gè)用戶(hù)獲得了紅包，改紅包將從紅包集合中移除
     * @return 紅包金額
     */
    public synchronized Integer getMoney(){
        if(moneys.size() <= 0){
            return 0;
        }
        int money = moneys.get(0);
        moneys.remove(0);
        return money;
    }
}

用戶(hù)線程：

 class GrabRedEnvelopeThread implements Runnable{
        /**
         * 該線程持有的用戶(hù)對(duì)象
         */
        private User user;
        /**
         * 所有線程共享的與分配金額
         */
        private Moneys moneys;

        GrabRedEnvelopeThread(User user,Moneys moneys){
            this.user = user;
            this.moneys = moneys;
        }

        @Override
        public void run() {
            try {
                int myMoney = moneys.getMoney();
                user.setMoney(myMoney);
                if(myMoney > 0){
                    user.setInfo(user.getName() + " 獲得 " +myMoney);
                }else {
                    user.setInfo(user.getName() + " 沒(méi)搶到");
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

紅包金額分配算法：相當(dāng)簡(jiǎn)陋的實(shí)現(xiàn)：

/**
     * 獲取隨機(jī)的紅包金額
     * @param number 紅包數(shù)量
     * @param money 紅包金額
     * @return 隨機(jī)紅包
     */
    private Moneys getRandomMoney(int number,int money){
        List moneys = new ArrayList<>();
        int averageMoney = money / number;
        for (int i = 0; i < number; i++) {
            if(i == (number - 1)){
                moneys.add(money - moneys.stream().mapToInt(m -> m.intValue()).sum());
            }else {
                moneys.add((int)(Math.random() * averageMoney +1));
            }
        }
        if(moneys.size() != number){
            System.out.println("nq");
        }
        return new Moneys(moneys);
    }

代碼模擬器：用于測(cè)試的客戶(hù)端

import java.util.*;
import java.util.concurrent.CompletableFuture;

/**
 * 搶紅包模擬器
 * @author ibm
 */
@SuppressWarnings("all")
public class BusinessSimulator {

    /**
     * 用戶(hù)群
     */
    private List users = Arrays.asList(new User("王一",0,""),
            new User("牛二",0,""),
            new User("張三",0,""),
            new User("李四",0,""),
            new User("吳五",0,""),
            new User("趙六",0,""),
            new User("枸七",0,""));
    /**
     * 發(fā)出的金額
     */
    private int money = 100;
    /**
     * 紅包數(shù)量
     */
    private int number = 3;

    public static void main(String[] args) throws InterruptedException {
        BusinessSimulator simulator = new BusinessSimulator();
        simulator.grabRedEnvelope(simulator.users,simulator.money,simulator.number);
        simulator.users.forEach(u -> {
            System.out.println(u.getInfo());
        });
    }

    /**
     * 搶紅包方法
     * @param users 用戶(hù)群
     * @param money 發(fā)出的金額
     * @param number 紅包數(shù)量
     * @return 用戶(hù)搶到紅包集合
     */
   private List grabRedEnvelope(List users,int money,int number) throws InterruptedException {

        //預(yù)分配金額
        Moneys moneys = getRandomMoney(number, money);
        List futures = new ArrayList<>();
        for (int index = 0; index < users.size(); index++) {
            Runnable run = new GrabRedEnvelopeThread(users.get(index),moneys);
            futures.add(CompletableFuture.runAsync(run));
        }
        CompletableFuture.allOf(futures.toArray(new CompletableFuture[futures.size()])).join();
        return users;
    }     
}

【結(jié)果