0 comments
6th Jun 10
cheng xu假想一个场景，需要通过迭代器来访问元素的后继(Binary Tree)
BinaryTree 类实现基本的二叉树的插入查找等功能:
01 public class BinaryTree {
02 public Node head;
03
04 public Node findMinNode(Node node) {
05 Node temp = node;
06 if (temp == null) {
07 return null;
08 }
09 while (temp.getLeftNode() != null) {
10 temp = temp.getLeftNode();
11 }
12 return temp;
13 }
14
15 public Node findMaxNode(Node node) {
16 Node temp = node;
17 if (temp == null) {
18 return null;
19 }
20 while (temp.getRightNode() != null) {
21 temp = temp.getRightNode();
22 }
23 return temp;
24 }
25
26 public Node searchNode(int x) {
27 Node node = head;
28 Node node1 = head;
29 if (head == null)
30 return null;
31 while (node1 != null) {
32 node = node1;
33 if (node.getElement() == x) {
34 return node;
35 } else if (node.getElement() > x) {
36 node1 = node.getLeftNode();
37 } else {
38 node1 = node.getRightNode();
39 }
40 }
41 return null;
42 }
43
44 public Node successor(Node x) {
45 if ((x == null) || (searchNode(x.getElement()) == null)) {
46 return null;
47 }
48 if (x.getRightNode() != null) {
49 return findMinNode(x.getRightNode());
50 }
51 Node y = x.getFather();
52 while ((y != null) && (x == y.getRightNode())) {
53 x = y;
54 y = y.getFather();
55 }
56 return y;
57 }
58
59 public void insert(int element) {
60 Node temp = head;
61 Node temp1 = head;
62 while (temp1 != null) {
63 temp = temp1;
64 if (temp.getElement() == element) {
65 return;
66 } else if (temp.getElement() > element) {
67 temp1 = temp.getLeftNode();
68 } else {
69 temp1 = temp.getRightNode();
70 }
71 }
72 if (temp == null) {
73 head = new Node();
74 head.setElement(element);
75 head.setFather(null);
76 } else {
77 Node node = new Node();
78 node.setElement(element);
79 node.setFather(temp);
80 if (temp.getElement() > element) {
81 temp.setLeftNode(node);
82 } else {
83 temp.setRightNode(node);
84 }
85 }
86 };
87 }
02 public Node head;
03
04 public Node findMinNode(Node node) {
05 Node temp = node;
06 if (temp == null) {
07 return null;
08 }
09 while (temp.getLeftNode() != null) {
10 temp = temp.getLeftNode();
11 }
12 return temp;
13 }
14
15 public Node findMaxNode(Node node) {
16 Node temp = node;
17 if (temp == null) {
18 return null;
19 }
20 while (temp.getRightNode() != null) {
21 temp = temp.getRightNode();
22 }
23 return temp;
24 }
25
26 public Node searchNode(int x) {
27 Node node = head;
28 Node node1 = head;
29 if (head == null)
30 return null;
31 while (node1 != null) {
32 node = node1;
33 if (node.getElement() == x) {
34 return node;
35 } else if (node.getElement() > x) {
36 node1 = node.getLeftNode();
37 } else {
38 node1 = node.getRightNode();
39 }
40 }
41 return null;
42 }
43
44 public Node successor(Node x) {
45 if ((x == null) || (searchNode(x.getElement()) == null)) {
46 return null;
47 }
48 if (x.getRightNode() != null) {
49 return findMinNode(x.getRightNode());
50 }
51 Node y = x.getFather();
52 while ((y != null) && (x == y.getRightNode())) {
53 x = y;
54 y = y.getFather();
55 }
56 return y;
57 }
58
59 public void insert(int element) {
60 Node temp = head;
61 Node temp1 = head;
62 while (temp1 != null) {
63 temp = temp1;
64 if (temp.getElement() == element) {
65 return;
66 } else if (temp.getElement() > element) {
67 temp1 = temp.getLeftNode();
68 } else {
69 temp1 = temp.getRightNode();
70 }
71 }
72 if (temp == null) {
73 head = new Node();
74 head.setElement(element);
75 head.setFather(null);
76 } else {
77 Node node = new Node();
78 node.setElement(element);
79 node.setFather(temp);
80 if (temp.getElement() > element) {
81 temp.setLeftNode(node);
82 } else {
83 temp.setRightNode(node);
84 }
85 }
86 };
87 }
Node节点类是基本元素
01 public class Node {
02 private Node father;
03 private Node leftNode;
04 private Node rightNode;
05 private int element;
06
07 public Node getFather() {
08 return father;
09 }
10
11 public void setFather(Node father) {
12 this.father = father;
13 }
14
15 public Node getLeftNode() {
16 return leftNode;
17 }
18
19 public void setLeftNode(Node leftNode) {
20 this.leftNode = leftNode;
21 }
22
23 public Node getRightNode() {
24 return rightNode;
25 }
26
27 public void setRightNode(Node rightNode) {
28 this.rightNode = rightNode;
29 }
30
31 public int getElement() {
32 return element;
33 }
34
35 public void setElement(int element) {
36 this.element = element;
37 }
38
39 }
02 private Node father;
03 private Node leftNode;
04 private Node rightNode;
05 private int element;
06
07 public Node getFather() {
08 return father;
09 }
10
11 public void setFather(Node father) {
12 this.father = father;
13 }
14
15 public Node getLeftNode() {
16 return leftNode;
17 }
18
19 public void setLeftNode(Node leftNode) {
20 this.leftNode = leftNode;
21 }
22
23 public Node getRightNode() {
24 return rightNode;
25 }
26
27 public void setRightNode(Node rightNode) {
28 this.rightNode = rightNode;
29 }
30
31 public int getElement() {
32 return element;
33 }
34
35 public void setElement(int element) {
36 this.element = element;
37 }
38
39 }
下面是迭代器，主要实现基本的访问功能
01 public class BinaryTreeIterator {
02 Object index;
03 BinaryTree bt;
04
05 public BinaryTreeIterator(BinaryTree bt) {
06 this.bt = bt;
07 index = bt.findMinNode(bt.head);
08 }
09
10 public Object first() {
11 return bt.head;
12 }
13
14 public void next() {
15 index = bt.successor((Node) index);
16 }
17
18 public boolean isDone() {
19 return index == null;
20 }
21
22 public Object currentItem() {
23 return index;
24 }
25 }
02 Object index;
03 BinaryTree bt;
04
05 public BinaryTreeIterator(BinaryTree bt) {
06 this.bt = bt;
07 index = bt.findMinNode(bt.head);
08 }
09
10 public Object first() {
11 return bt.head;
12 }
13
14 public void next() {
15 index = bt.successor((Node) index);
16 }
17
18 public boolean isDone() {
19 return index == null;
20 }
21
22 public Object currentItem() {
23 return index;
24 }
25 }
代理模式，封装一部分操作
01 public class BinaryTreeProxy {
02 private BinaryTree bt;
03
04 public BinaryTreeProxy(BinaryTree bt) {
05 this.bt = bt;
06 }
07
08 public void insert(int element) {
09 bt.insert(element);
10 }
11
12 public Node searchNode(int x) {
13 return bt.searchNode(x);
14 }
15
16 public Node findMaxNode(Node node) {
17 if (node == null) {
18 return null;
19 }
20 if (searchNode(node.getElement()) == null) {
21 return null;
22 }
23 return bt.findMaxNode(node);
24 }
25
26 public Node findMinNode(Node node) {
27 if (node == null) {
28 return null;
29 }
30 if (searchNode(node.getElement()) == null) {
31 return null;
32 }
33 return bt.findMinNode(node);
34 }
35
36 public Node successor(Node x) {
37 if (x == null) {
38 return null;
39 }
40 if (searchNode(x.getElement()) == null) {
41 return null;
42 }
43 return bt.successor(x);
44 }
45 }
02 private BinaryTree bt;
03
04 public BinaryTreeProxy(BinaryTree bt) {
05 this.bt = bt;
06 }
07
08 public void insert(int element) {
09 bt.insert(element);
10 }
11
12 public Node searchNode(int x) {
13 return bt.searchNode(x);
14 }
15
16 public Node findMaxNode(Node node) {
17 if (node == null) {
18 return null;
19 }
20 if (searchNode(node.getElement()) == null) {
21 return null;
22 }
23 return bt.findMaxNode(node);
24 }
25
26 public Node findMinNode(Node node) {
27 if (node == null) {
28 return null;
29 }
30 if (searchNode(node.getElement()) == null) {
31 return null;
32 }
33 return bt.findMinNode(node);
34 }
35
36 public Node successor(Node x) {
37 if (x == null) {
38 return null;
39 }
40 if (searchNode(x.getElement()) == null) {
41 return null;
42 }
43 return bt.successor(x);
44 }
45 }
Mian函数用来测试
01 public class Main {
02
03 /**
04 * @param args
05 */
06 public static void main(String[] args) {
07 BinaryTree bt = new BinaryTree();
08 bt.insert(7);
09 bt.insert(10);
10 bt.insert(9);
11 bt.insert(13);
12 bt.insert(5);
13 bt.insert(2);
14 bt.insert(6);
15 BinaryTreeIterator bti = new BinaryTreeIterator(bt);
16 for(;!bti.isDone();bti.next()){
17 System.out.println(((Node)bti.currentItem()).getElement());
18 }
19 }
20
21 }
02
03 /**
04 * @param args
05 */
06 public static void main(String[] args) {
07 BinaryTree bt = new BinaryTree();
08 bt.insert(7);
09 bt.insert(10);
10 bt.insert(9);
11 bt.insert(13);
12 bt.insert(5);
13 bt.insert(2);
14 bt.insert(6);
15 BinaryTreeIterator bti = new BinaryTreeIterator(bt);
16 for(;!bti.isDone();bti.next()){
17 System.out.println(((Node)bti.currentItem()).getElement());
18 }
19 }
20
21 }
下面是调停者模式
所有的参与者(Colleague)都继承该类
01 package CardShark;
02
03 public class Colleague {
04 private Mediator mediator;
05
06 public Colleague(Mediator mediator) {
07 this.mediator = mediator;
08 }
09
10 public Mediator getMediator() {
11 return mediator;
12 }
13
14 public void setMediator(Mediator mediator) {
15 this.mediator = mediator;
16 }
17 }
02
03 public class Colleague {
04 private Mediator mediator;
05
06 public Colleague(Mediator mediator) {
07 this.mediator = mediator;
08 }
09
10 public Mediator getMediator() {
11 return mediator;
12 }
13
14 public void setMediator(Mediator mediator) {
15 this.mediator = mediator;
16 }
17 }
参与者有cardsender，player，container
01 package CardShark;
02
03 public class Colleague {
04 private Mediator mediator;
05
06 public Colleague(Mediator mediator) {
07 this.mediator = mediator;
08 }
09
10 public Mediator getMediator() {
11 return mediator;
12 }
13
14 public void setMediator(Mediator mediator) {
15 this.mediator = mediator;
16 }
17 }
02
03 public class Colleague {
04 private Mediator mediator;
05
06 public Colleague(Mediator mediator) {
07 this.mediator = mediator;
08 }
09
10 public Mediator getMediator() {
11 return mediator;
12 }
13
14 public void setMediator(Mediator mediator) {
15 this.mediator = mediator;
16 }
17 }
001 package CardShark;
002
003 import java.io.BufferedReader;
004 import java.io.IOException;
005 import java.io.InputStreamReader;
006
007 public class Player extends Colleague {
008 String name;
009 status status;
010 double stack;
011
012 public Player(Mediator mediator) {
013 super(mediator);
014 status = status.Null;
015 stack = 0;
016 }
017
018 public void getStackBegin() {
019 status = status.PutStack;
020 System.out.println(“玩家 “ + name + ” 获知开始下注”);
021 this.setStack();
022 this.noticeNextPlayerStack();
023 }
024
025 public void setStack() {
026 System.out
027 .print(“Hi “ + name + “,you should enter the Amount of fees:”);
028 BufferedReader bf = new BufferedReader(new InputStreamReader(System.in));
029 try {
030 double stack = Double.parseDouble(bf.readLine());
031 super.getMediator().addAmount(stack);
032 System.out.println(“玩家 “ + name + “开始下注”);
033 this.stack = stack;
034 } catch (NumberFormatException e) {
035 e.printStackTrace();
036 } catch (IOException e) {
037 e.printStackTrace();
038 }
039 }
040
041 public void noticeNextPlayerStack() {
042 System.out.println(“玩家 “ + name + “通知下一个下注的玩家”);
043 super.getMediator().noticeNextPlayerStackByPlayer();
044 }
045
046 public void getGamblingBegin(Player player, double total) {
047 System.out.println(“玩家 “ + name + “接到通知开始赌博”);
048 status = status.Gambling;
049 if (this.isLastOne()) {
050 this.finished(player, total);
051 } else {
052 this.chooseOptioins(player, total);
053 }
054 }
055
056 public void chooseOptioins(Player player, double total) {
057 String name = “暂无人下注”;
058 if (player != null)
059 name = player.name;
060 System.out
061 .print(“The last add person is “
062 + name
063 + ” and the total number is “
064 + total
065 + “. You should choose one option among add, withdraw or not set by 1,2,3(default 3)”);
066 BufferedReader bf = new BufferedReader(new InputStreamReader(System.in));
067 try {
068 int choice = Integer.parseInt(bf.readLine());
069 switch (choice) {
070 case 1:
071 System.out.print(“input the amount:”);
072 double moreStack = Double.parseDouble(bf.readLine());
073 this.addAmount(moreStack);
074 this.noticeNextGamblingPlayer();
075 break;
076 case 2:
077 this.withdraw();
078 break;
079 default:
080 this.notSet();
081 this.noticeNextGamblingPlayer();
082 break;
083 }
084 } catch (NumberFormatException e) {
085 e.printStackTrace();
086 } catch (IOException e) {
087 e.printStackTrace();
088 }
089
090 }
091
092 private void addAmount(double moreStack) {
093 this.stack += moreStack;
094 super.getMediator().addStack(this);
095 }
096
097 private void withdraw() {
098 super.getMediator().withdraw(this);
099 }
100
101 private void notSet() {
102 super.getMediator().notSet(this);
103 }
104
105 public void noticeNextGamblingPlayer() {
106 super.getMediator().noticeNextGamblingPlayerByPlayer();
107 }
108
109 public void sendSecondPlayerByPlayer() {
110 super.getMediator().noticeSecondGamblingPlayer();
111 }
112
113 public boolean isLastOne() {
114 return super.getMediator().isLastOne(this);
115 }
116
117 public void finished(Player player, double total) {
118 String name = “暂无人下注”;
119 if (player != null)
120 name = player.name;
121 System.out.print(“赌博结束，最后下注者为 “ + name
122 + ” 总数为 “ + total);
123
124 }
125 }
002
003 import java.io.BufferedReader;
004 import java.io.IOException;
005 import java.io.InputStreamReader;
006
007 public class Player extends Colleague {
008 String name;
009 status status;
010 double stack;
011
012 public Player(Mediator mediator) {
013 super(mediator);
014 status = status.Null;
015 stack = 0;
016 }
017
018 public void getStackBegin() {
019 status = status.PutStack;
020 System.out.println(“玩家 “ + name + ” 获知开始下注”);
021 this.setStack();
022 this.noticeNextPlayerStack();
023 }
024
025 public void setStack() {
026 System.out
027 .print(“Hi “ + name + “,you should enter the Amount of fees:”);
028 BufferedReader bf = new BufferedReader(new InputStreamReader(System.in));
029 try {
030 double stack = Double.parseDouble(bf.readLine());
031 super.getMediator().addAmount(stack);
032 System.out.println(“玩家 “ + name + “开始下注”);
033 this.stack = stack;
034 } catch (NumberFormatException e) {
035 e.printStackTrace();
036 } catch (IOException e) {
037 e.printStackTrace();
038 }
039 }
040
041 public void noticeNextPlayerStack() {
042 System.out.println(“玩家 “ + name + “通知下一个下注的玩家”);
043 super.getMediator().noticeNextPlayerStackByPlayer();
044 }
045
046 public void getGamblingBegin(Player player, double total) {
047 System.out.println(“玩家 “ + name + “接到通知开始赌博”);
048 status = status.Gambling;
049 if (this.isLastOne()) {
050 this.finished(player, total);
051 } else {
052 this.chooseOptioins(player, total);
053 }
054 }
055
056 public void chooseOptioins(Player player, double total) {
057 String name = “暂无人下注”;
058 if (player != null)
059 name = player.name;
060 System.out
061 .print(“The last add person is “
062 + name
063 + ” and the total number is “
064 + total
065 + “. You should choose one option among add, withdraw or not set by 1,2,3(default 3)”);
066 BufferedReader bf = new BufferedReader(new InputStreamReader(System.in));
067 try {
068 int choice = Integer.parseInt(bf.readLine());
069 switch (choice) {
070 case 1:
071 System.out.print(“input the amount:”);
072 double moreStack = Double.parseDouble(bf.readLine());
073 this.addAmount(moreStack);
074 this.noticeNextGamblingPlayer();
075 break;
076 case 2:
077 this.withdraw();
078 break;
079 default:
080 this.notSet();
081 this.noticeNextGamblingPlayer();
082 break;
083 }
084 } catch (NumberFormatException e) {
085 e.printStackTrace();
086 } catch (IOException e) {
087 e.printStackTrace();
088 }
089
090 }
091
092 private void addAmount(double moreStack) {
093 this.stack += moreStack;
094 super.getMediator().addStack(this);
095 }
096
097 private void withdraw() {
098 super.getMediator().withdraw(this);
099 }
100
101 private void notSet() {
102 super.getMediator().notSet(this);
103 }
104
105 public void noticeNextGamblingPlayer() {
106 super.getMediator().noticeNextGamblingPlayerByPlayer();
107 }
108
109 public void sendSecondPlayerByPlayer() {
110 super.getMediator().noticeSecondGamblingPlayer();
111 }
112
113 public boolean isLastOne() {
114 return super.getMediator().isLastOne(this);
115 }
116
117 public void finished(Player player, double total) {
118 String name = “暂无人下注”;
119 if (player != null)
120 name = player.name;
121 System.out.print(“赌博结束，最后下注者为 “ + name
122 + ” 总数为 “ + total);
123
124 }
125 }
01 package CardShark;
02
03 public class Container extends Colleague {
04 status status;
05 Player lastAddMan;
06 double totalStack;
07
08 public Container(Mediator mediator) {
09 super(mediator);
10 this.status = status.Null;
11 lastAddMan = null;
12 }
13
14 public void startStack() {
15 status = status.PutStack;
16 totalStack = 0;
17 System.out.println(“容器获得开始下注信息”);
18 }
19
20 //开始下注或者开始加注
21 public void addStack(double adds){
22 totalStack+=adds;
23 }
24
25 public void startGambling() {
26 status = status.Gambling;
27 System.out.println(“容器获得开始下赌博信息”);
28 }
29
30 public status getStatus() {
31 return status;
32 }
33
34 public void setStatus(status status) {
35 this.status = status;
36 }
37
38 public Player getLastAddMan() {
39 return lastAddMan;
40 }
41
42 public void setLastAddMan(Player lastAddMan) {
43 this.lastAddMan = lastAddMan;
44 }
45
46 public double getTotalStack() {
47 return totalStack;
48 }
49
50 public void setTotalStack(double totalStack) {
51 this.totalStack = totalStack;
52 }
53
54 }
02
03 public class Container extends Colleague {
04 status status;
05 Player lastAddMan;
06 double totalStack;
07
08 public Container(Mediator mediator) {
09 super(mediator);
10 this.status = status.Null;
11 lastAddMan = null;
12 }
13
14 public void startStack() {
15 status = status.PutStack;
16 totalStack = 0;
17 System.out.println(“容器获得开始下注信息”);
18 }
19
20 //开始下注或者开始加注
21 public void addStack(double adds){
22 totalStack+=adds;
23 }
24
25 public void startGambling() {
26 status = status.Gambling;
27 System.out.println(“容器获得开始下赌博信息”);
28 }
29
30 public status getStatus() {
31 return status;
32 }
33
34 public void setStatus(status status) {
35 this.status = status;
36 }
37
38 public Player getLastAddMan() {
39 return lastAddMan;
40 }
41
42 public void setLastAddMan(Player lastAddMan) {
43 this.lastAddMan = lastAddMan;
44 }
45
46 public double getTotalStack() {
47 return totalStack;
48 }
49
50 public void setTotalStack(double totalStack) {
51 this.totalStack = totalStack;
52 }
53
54 }
01 package CardShark;
02
03 public class CardSender extends Colleague {
04
05 public CardSender(Mediator mediator) {
06 super(mediator);
07 }
08
09 public void startStack(){
10 this.noticeStartStack();
11 this.noticeNextPlayerStack();
12 }
13
14 // 通知开发下注
15 public void noticeStartStack() {
16 System.out.println(“发牌人通知下注开始”);
17 super.getMediator().noticeBeginStack();
18 }
19
20 //通知下一个玩家下注
21 public void noticeNextPlayerStack() {
22 System.out.println(“发牌人通知下一个玩家开始下注”);
23 super.getMediator().noticeNextPlayerStackByCardSender();
24 }
25
26 public void GetStackInfoFromUser(){
27 System.out.println(“发牌人受到下注信息，下注停止”);
28 }
29
30 public void startGambling(){
31 this.noticeStartGambling();
32 this.noticeNextPlayerGamblingBySender();
33 }
34
35 public void noticeStartGambling() {
36 System.out.println(“发牌人通知容器赌博开始”);
37 super.getMediator().noticeBeginGambling();
38 }
39
40 public void noticeNextPlayerGamblingBySender() {
41 System.out.println(“发牌人通知下一个玩家开始赌博开始”);
42 super.getMediator().noticeBeginGamblingBySender();
43 }
44
45 public void noticeSecondPlayerGamblingBySender(Player player){
46 System.out.println(“发牌人收到”+ player.name+“通知将信息发给该用户左边的用户”);
47 super.getMediator().noticeSecondPlayerGamblingBySender();
48 }
49 }
02
03 public class CardSender extends Colleague {
04
05 public CardSender(Mediator mediator) {
06 super(mediator);
07 }
08
09 public void startStack(){
10 this.noticeStartStack();
11 this.noticeNextPlayerStack();
12 }
13
14 // 通知开发下注
15 public void noticeStartStack() {
16 System.out.println(“发牌人通知下注开始”);
17 super.getMediator().noticeBeginStack();
18 }
19
20 //通知下一个玩家下注
21 public void noticeNextPlayerStack() {
22 System.out.println(“发牌人通知下一个玩家开始下注”);
23 super.getMediator().noticeNextPlayerStackByCardSender();
24 }
25
26 public void GetStackInfoFromUser(){
27 System.out.println(“发牌人受到下注信息，下注停止”);
28 }
29
30 public void startGambling(){
31 this.noticeStartGambling();
32 this.noticeNextPlayerGamblingBySender();
33 }
34
35 public void noticeStartGambling() {
36 System.out.println(“发牌人通知容器赌博开始”);
37 super.getMediator().noticeBeginGambling();
38 }
39
40 public void noticeNextPlayerGamblingBySender() {
41 System.out.println(“发牌人通知下一个玩家开始赌博开始”);
42 super.getMediator().noticeBeginGamblingBySender();
43 }
44
45 public void noticeSecondPlayerGamblingBySender(Player player){
46 System.out.println(“发牌人收到”+ player.name+“通知将信息发给该用户左边的用户”);
47 super.getMediator().noticeSecondPlayerGamblingBySender();
48 }
49 }
容器的状态类
1 package CardShark;
2
3 public enum status {
4 Null,PutStack,Gambling,End
5 }
2
3 public enum status {
4 Null,PutStack,Gambling,End
5 }
这个是调停者(Mediator)，主要是集中式控制
001 package CardShark;
002
003 import java.util.ArrayList;
004 import java.util.Iterator;
005
006 public class Mediator {
007 CardSender cardSender;
008 ArrayList<Player> players;
009 Container container;
010 Iterator<Player> iterator;
011
012 public Mediator() {
013 players = new ArrayList<Player>();
014 }
015
016 public void registerPlayer(Player player) {
017 this.players.add(player);
018 }
019
020 public void registerContainer(Container container) {
021 this.container = container;
022 }
023
024 public void registerCardSender(CardSender cardSender) {
025 this.cardSender = cardSender;
026 }
027
028 public void noticeBeginStack() {
029 iterator = players.iterator();
030 container.startStack();
031 }
032
033 // 由发牌人通知下一个玩家开始下注
034 public void noticeNextPlayerStackByCardSender() {
035 (iterator.next()).getStackBegin();
036 }
037
038 // 增加下注数量和下注金额
039 public void addAmount(double amount) {
040 container.addStack(amount);
041 }
042
043 // 由参与者通知下一个玩家开始下注
044 public void noticeNextPlayerStackByPlayer() {
045 if (iterator.hasNext()) {
046 (iterator.next()).getStackBegin();
047 } else {
048 cardSender.GetStackInfoFromUser();
049 }
050 }
051
052 public void noticeBeginGambling() {
053 iterator = players.iterator();
054 container.startGambling();
055 }
056
057 public void noticeBeginGamblingBySender() {
058 (iterator.next()).getGamblingBegin(null, container.totalStack);
059 }
060
061 public void addStack(Player player) {
062 container.setLastAddMan(player);
063 container.addStack(player.stack);
064 }
065
066 public void withdraw(Player player) {
067 if(isLastOne(player)){
068 player.finished(container.lastAddMan,container.totalStack);
069 }else if(isFirstOne(player)){
070 cardSender.noticeSecondPlayerGamblingBySender(player);
071 }else{
072 Iterator<Player> temp = players.iterator();
073 Player previousOne = temp.next();
074 Player currentOne = previousOne;
075 while(temp.hasNext()){
076 previousOne = currentOne;
077 currentOne = temp.next();
078 if(currentOne == player){
079 break;
080 }
081 }
082 iterator = players.iterator();
083 while(iterator.hasNext()){
084 if(iterator.next()==previousOne){
085 break;
086 }
087 }
088 previousOne.sendSecondPlayerByPlayer();
089 }
090 }
091
092 public void noticeSecondPlayerGamblingBySender(){
093 iterator.next().getGamblingBegin(null,container.totalStack);
094 }
095
096 public boolean isFirstOne(Player player){
097 Iterator<Player> temp = players.iterator();
098 return temp.next()== player;
099 }
100
101 public boolean isLastOne(Player player){
102 boolean has = false;
103 Iterator<Player> temp = players.iterator();
104 Player player2 =null;
105 while (temp.hasNext()) {
106 player2 = temp.next();
107 }
108 return player2==player;
109 }
110
111 public void notSet(Player player) {
112 System.out.println();
113 container.addStack(player.stack);
114 }
115
116 public void noticeNextGamblingPlayerByPlayer(){
117 if (iterator.hasNext()) {
118 (iterator.next()).getGamblingBegin(container.lastAddMan,container.totalStack);
119 }else{
120 System.out.println(“这是最后一个玩家，赌博结束，最后总的赌注为” + container.getTotalStack());
121 }
122 }
123
124 public void noticeSecondGamblingPlayer(){
125 iterator.next();
126 iterator.next().getGamblingBegin(container.lastAddMan,container.totalStack);
127 }
128 }
002
003 import java.util.ArrayList;
004 import java.util.Iterator;
005
006 public class Mediator {
007 CardSender cardSender;
008 ArrayList<Player> players;
009 Container container;
010 Iterator<Player> iterator;
011
012 public Mediator() {
013 players = new ArrayList<Player>();
014 }
015
016 public void registerPlayer(Player player) {
017 this.players.add(player);
018 }
019
020 public void registerContainer(Container container) {
021 this.container = container;
022 }
023
024 public void registerCardSender(CardSender cardSender) {
025 this.cardSender = cardSender;
026 }
027
028 public void noticeBeginStack() {
029 iterator = players.iterator();
030 container.startStack();
031 }
032
033 // 由发牌人通知下一个玩家开始下注
034 public void noticeNextPlayerStackByCardSender() {
035 (iterator.next()).getStackBegin();
036 }
037
038 // 增加下注数量和下注金额
039 public void addAmount(double amount) {
040 container.addStack(amount);
041 }
042
043 // 由参与者通知下一个玩家开始下注
044 public void noticeNextPlayerStackByPlayer() {
045 if (iterator.hasNext()) {
046 (iterator.next()).getStackBegin();
047 } else {
048 cardSender.GetStackInfoFromUser();
049 }
050 }
051
052 public void noticeBeginGambling() {
053 iterator = players.iterator();
054 container.startGambling();
055 }
056
057 public void noticeBeginGamblingBySender() {
058 (iterator.next()).getGamblingBegin(null, container.totalStack);
059 }
060
061 public void addStack(Player player) {
062 container.setLastAddMan(player);
063 container.addStack(player.stack);
064 }
065
066 public void withdraw(Player player) {
067 if(isLastOne(player)){
068 player.finished(container.lastAddMan,container.totalStack);
069 }else if(isFirstOne(player)){
070 cardSender.noticeSecondPlayerGamblingBySender(player);
071 }else{
072 Iterator<Player> temp = players.iterator();
073 Player previousOne = temp.next();
074 Player currentOne = previousOne;
075 while(temp.hasNext()){
076 previousOne = currentOne;
077 currentOne = temp.next();
078 if(currentOne == player){
079 break;
080 }
081 }
082 iterator = players.iterator();
083 while(iterator.hasNext()){
084 if(iterator.next()==previousOne){
085 break;
086 }
087 }
088 previousOne.sendSecondPlayerByPlayer();
089 }
090 }
091
092 public void noticeSecondPlayerGamblingBySender(){
093 iterator.next().getGamblingBegin(null,container.totalStack);
094 }
095
096 public boolean isFirstOne(Player player){
097 Iterator<Player> temp = players.iterator();
098 return temp.next()== player;
099 }
100
101 public boolean isLastOne(Player player){
102 boolean has = false;
103 Iterator<Player> temp = players.iterator();
104 Player player2 =null;
105 while (temp.hasNext()) {
106 player2 = temp.next();
107 }
108 return player2==player;
109 }
110
111 public void notSet(Player player) {
112 System.out.println();
113 container.addStack(player.stack);
114 }
115
116 public void noticeNextGamblingPlayerByPlayer(){
117 if (iterator.hasNext()) {
118 (iterator.next()).getGamblingBegin(container.lastAddMan,container.totalStack);
119 }else{
120 System.out.println(“这是最后一个玩家，赌博结束，最后总的赌注为” + container.getTotalStack());
121 }
122 }
123
124 public void noticeSecondGamblingPlayer(){
125 iterator.next();
126 iterator.next().getGamblingBegin(container.lastAddMan,container.totalStack);
127 }
128 }
测试类
01 package CardShark;
02
03 public class Main {
04
05 /**
06 * @param args
07 */
08 public static void main(String[] args) {
09 //初始化
10 //新建调停者
11 Mediator mediator = new Mediator();
12
13 //注册容器
14 Container container = new Container(mediator);
15 mediator.registerContainer(container);
16
17 //注册会员
18 Player player1 = new Player(mediator);
19 player1.name = “Tom”;
20 mediator.registerPlayer(player1);
21
22 Player player2 = new Player(mediator);
23 player2.name = “Mike”;
24 mediator.registerPlayer(player2);
25
26 Player player3 = new Player(mediator);
27 player3.name = “Jim”;
28 mediator.registerPlayer(player3);
29
30 Player player4 = new Player(mediator);
31 player4.name = “Hebe”;
32 mediator.registerPlayer(player4);
33
34
35 //注册发牌人
36 CardSender cardSender = new CardSender(mediator);
37 mediator.registerCardSender(cardSender);
38
39 //开始下注
40 cardSender.startStack();
41
42 //赌博开始
43 cardSender.startGambling();
44 }
45
46 }
02
03 public class Main {
04
05 /**
06 * @param args
07 */
08 public static void main(String[] args) {
09 //初始化
10 //新建调停者
11 Mediator mediator = new Mediator();
12
13 //注册容器
14 Container container = new Container(mediator);
15 mediator.registerContainer(container);
16
17 //注册会员
18 Player player1 = new Player(mediator);
19 player1.name = “Tom”;
20 mediator.registerPlayer(player1);
21
22 Player player2 = new Player(mediator);
23 player2.name = “Mike”;
24 mediator.registerPlayer(player2);
25
26 Player player3 = new Player(mediator);
27 player3.name = “Jim”;
28 mediator.registerPlayer(player3);
29
30 Player player4 = new Player(mediator);
31 player4.name = “Hebe”;
32 mediator.registerPlayer(player4);
33
34
35 //注册发牌人
36 CardSender cardSender = new CardSender(mediator);
37 mediator.registerCardSender(cardSender);
38
39 //开始下注
40 cardSender.startStack();
41
42 //赌博开始
43 cardSender.startGambling();
44 }
45
46 }
