Skip to content

Commit f032799

Browse files
authored
Create Server.java
1 parent 451169a commit f032799

File tree

1 file changed

+34
-0
lines changed

1 file changed

+34
-0
lines changed

src/servers/Server.java

+34
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
package servers;
2+
3+
import java.util.ArrayList;
4+
import java.util.concurrent.LinkedBlockingQueue;
5+
6+
public class Server
7+
{
8+
private static final int DEFAULT_PORT = 4;
9+
private static final int DEFAULT_BACKLOG = 10;
10+
11+
private int port;
12+
private int backlog;
13+
14+
private ArrayList<ClientConnection> clientConnectionList;
15+
private LinkedBlockingQueue<String> clientMessageList;
16+
17+
public Server(int port, int backlog) {
18+
this.port = port;
19+
this.backlog = backlog;
20+
clientConnectionList = new ArrayList<ClientConnection>();
21+
clientMessageList = new LinkedBlockingQueue<String>();
22+
}
23+
24+
public void start()
25+
{
26+
new Thread ( new ServerListener(port, backlog, clientConnectionList, clientMessageList) ).start();
27+
new Thread( new ServerSender(clientConnectionList, clientMessageList) ).start();
28+
}
29+
30+
public static void main(String[] Args) {
31+
Server server = new Server(Server.DEFAULT_PORT, Server.DEFAULT_BACKLOG);
32+
server.start();
33+
}
34+
}

0 commit comments

Comments
 (0)