package threadtest;


import java.util.*;


/**
 * desc:
 * User: weiguili([email protected])
 * Date: 13-11-12
 * Time: 下午2:24
 */
public class ThreadTest2 {
    /**
     * @param args
     */
    public static void main(String[] args) {
        PokerSender pokers=new PokerSender();
        Players a=new Players("A",pokers);
        Players b=new Players("B",pokers);
        Players c=new Players("C",pokers);
        Players d=new Players("D",pokers);
        a.setNext(b);
        b.setNext(c);
        c.setNext(d);
        d.setNext(a);
        a.start();
    }
}
//撲克發牌器
class PokerSender {
    public final int POKER_NUM = 52;//一共52張
    public final boolean IS_RAMDOM = false;//牌是否隨機打亂
    public final int PLAY_NUM =4;//玩家數量
    public int sendNum =0;//已經發了多少張牌
    private List<Integer> poker = new ArrayList<Integer>();//撲克
    public List<Map<String,List<Integer>>> allHanderCards = new ArrayList<Map<String, List<Integer>>>(); //收集所有人手中的牌
    public  int getNext(){
        return sendNum++;
    }
    PokerSender(){
        setPokers();
    }
    public void showAllCards(){
        System.out.println(allHanderCards);
    }
    public synchronized void setPokers(){//從新洗牌
        for(int i =0;i<POKER_NUM; i++){
            poker.add(i);
        }
        if(IS_RAMDOM){ //如果隨機則打散
            java.util.Random rand=new Random(); //隨機數序列物件
            java.util.Collections.shuffle(poker, rand); //將列表的資料序列打散，按隨機數序列
        }
    }


    public synchronized int sendPokers(int index){//同步發牌
        return poker.get(index);
    }
    public boolean isLastTurn(){//是否最後一輪
        return sendNum > getPokersNum()- PLAY_NUM;
    }
    public int getPokersNum(){
        return poker.size();
    }
}


//執行緒(也就是玩家)
class Players extends Thread {
    private PokerSender pokers;//撲克
    private Players next;//下一家
    public List<Integer> handerCards = new ArrayList<Integer>(); //發到手的牌
    public Players(String name, PokerSender poker){
        this.setName(name);
        this.pokers =poker;
    }
    public void setNext(Players next){
        this.next=next;
    }
    public void setHanderCards(int cards){
        handerCards.add(cards);
    }
    public void cllectAll(){
        if(pokers.isLastTurn()) { //最後一輪，收牌。
            Map<String,List<Integer>> map = new HashMap<String, List<Integer>>();
            map.put(getName(),handerCards);
            pokers.allHanderCards.add(map);
        }
    }
    public void showCards(){
        if(pokers.isLastTurn()) { //最後一輪，該攤牌了。
            System.out.println(handerCards);
        }
    }


    public void run(){
        int sendNum= pokers.getNext();
        while(sendNum<pokers.getPokersNum()){
            sendNum = getPoker(sendNum);
        }
        pokers.showAllCards();
        System.exit(0);
    }


    /**
     * 摸牌
     * @param sendNum 發了多少張牌
     * @return
     */
    private synchronized int getPoker(int sendNum) {
        System.out.println(getName()+"摸到牌"+sendNum);
        setHanderCards(pokers.sendPokers(sendNum));
        this.showCards();
        this.cllectAll();
        if(this.next.getState()== State.NEW){//第一輪 下一個執行緒如果還沒開始則啟動它
            this.next.start();
        }else{
            synchronized (this.next) {//喚醒下一個程序
                this.next.notify();
            }
        }
        try { //阻塞當前程序
            this.wait();
        } catch (Exception e) {
            e.printStackTrace();
        }
        sendNum= pokers.getNext();
        if(sendNum%pokers.PLAY_NUM ==0){
            System.out.println("--------------------完成"+sendNum/pokers.PLAY_NUM +"輪----------------");
        }
        return sendNum;
    }
}