Skip to content
Snippets Groups Projects

Add comment

Merged maitp2 requested to merge add_commend into main
1 file
+ 14
7
Compare changes
  • Side-by-side
  • Inline
package cs425.mp2;
import java.io.*;
import java.net.DatagramPacket;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.*;
@@ -33,8 +32,21 @@ public class Member extends Thread {
logger.info("Member " + memberInfo.getHost() + " started");
}
/*
this function has two responsibilities:
- Ping random k (=4) members adjacent to it
- Wait for user command from commandline
*/
ExecutorService executors = Executors.newFixedThreadPool(3);
SWIMPing(executors);
while (true) {
readCommand();
}
}
protected void SWIMPing(ExecutorService executors) {
executors.execute(new Runnable() {
@Override
public void run() {
@@ -48,14 +60,9 @@ public class Member extends Thread {
}
}
});
while (true) {
readCommand();
}
}
private void readCommand() {
protected void readCommand() {
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
String command = null;
try {
Loading