-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathGameThread.java
executable file
·81 lines (75 loc) · 3.19 KB
/
GameThread.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
import java.io.*;
import java.net.Socket;
/**
* Created by shenchengyu on 15/2/2.
*/
public class GameThread implements Runnable {
Socket s;
public GameThread(Socket s){
this.s = s;
}
@Override
public void run() {
boolean duplicate= false;
try {
OutputStreamWriter osw = new OutputStreamWriter(s.getOutputStream());
InputStream is = s.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String line;
while ((line =br.readLine())!=null){
String[] split = line.split("\\s");
if (!split[0].equals("SHOW")) {
try {
for (int j= GameServer.getPlayer().size() - 1; j>=0; j--){
if (GameServer.getPlayer().get(j).equals(split[0])){
if (GameServer.getScore().get(j) < Integer.parseInt(split[1])){
GameServer.getScore().set(j, Integer.parseInt(split[1]));
}
duplicate=true;
break;
}
}
if (!duplicate) {
GameServer.getPlayer().add(split[0]);
GameServer.getScore().add(Integer.parseInt(split[1]));
//avoid the same ID
//insert the new element to its corresponding position in descending order.
for (int j = GameServer.getPlayer().size() - 2; j >= 0; j--) {
if (GameServer.getScore().get(j + 1) > GameServer.getScore().get(j)) {
String holdName = GameServer.getPlayer().get(j + 1);
int holdValue = GameServer.getScore().get(j + 1);
GameServer.getPlayer().set(j + 1, GameServer.getPlayer().get(j));
GameServer.getScore().set(j + 1, GameServer.getScore().get(j));
GameServer.getPlayer().set(j, holdName);
GameServer.getScore().set(j, holdValue);
} else {
break;
}
}
}
}
catch (Exception e){
System.out.println("doesn't input a name");
}
}
else {
int i = 0;
while (i<GameServer.getPlayer().size()&&i<=10){
osw.write(GameServer.getPlayer().get(i)+" "+GameServer.getScore().get(i)+"\n");
osw.flush();
i++;
}
osw.write("end\n");
osw.flush();
}
}
} catch (IOException e) {
e.printStackTrace();
}
try {
s.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}