~ remove sleep.

pull/1/head
Ivan Olexyn 5 years ago
parent a871e3cf2f
commit 4548be3076

@ -23,12 +23,7 @@ public class AppMock extends ActorRunnable {
@Override @Override
public void run() { public void run() {
while (true) { while (true) {
try {
Thread.sleep(Main.WAIT_SPEED);
} catch (InterruptedException e) {
e.printStackTrace();
}
} }
} }

@ -9,18 +9,30 @@ import exchange.ExchangeMock;
public class UserMock extends ActorRunnable { public class UserMock extends ActorRunnable {
final String longRequest;
int requestCount = 0; int requestCount = 0;
public UserMock(MockSet mockSet){ public UserMock(MockSet mockSet){
super(mockSet); super(mockSet);
mockSet.userMock = this; mockSet.userMock = this;
StringBuilder sb = new StringBuilder();
for (int i=0;i<100;i++){
sb.append("foo");
}
longRequest = sb.toString();
} }
@Override @Override
public void run() { public void run() {
while (true){ while (true){
try { try {
Thread.sleep(Main.WAIT_SPEED);
sendGetRequest(); sendGetRequest();
} catch (IOException | InterruptedException e) { } catch (IOException | InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
@ -52,6 +64,8 @@ public class UserMock extends ActorRunnable {
exchange.request.setMethod("GET"); exchange.request.setMethod("GET");
//exchange.request.setContentType("application/json"); //exchange.request.setContentType("application/json");
//String requestBody = longRequest+"-"+(++requestCount);
String requestBody = "REQUEST-"+(++requestCount); String requestBody = "REQUEST-"+(++requestCount);
String jsonString = "{\"request\":\""+requestBody+ "\"}"; String jsonString = "{\"request\":\""+requestBody+ "\"}";
exchange.request.setContent(jsonString.getBytes()); exchange.request.setContent(jsonString.getBytes());
@ -64,7 +78,7 @@ public class UserMock extends ActorRunnable {
// handle OK (Data) // handle OK (Data)
String data = exchange.response.getContentAsString(); String data = exchange.response.getContentAsString();
System.out.println(data + " of REQUEST-"+requestCount); System.out.println(data + " of "+requestBody);
exchange.notify(); exchange.notify();
} }
} }

@ -40,7 +40,6 @@ public class BridgeMock extends BridgeServlet {
while (available.size() < 1) { while (available.size() < 1) {
available.notify(); available.notify();
Thread.sleep(Main.WAIT_SPEED);
available.wait(); available.wait();
} }
// ride exists only locally, thus safe // ride exists only locally, thus safe
@ -64,7 +63,6 @@ public class BridgeMock extends BridgeServlet {
while (!loaded.containsKey(ride.getID())) { while (!loaded.containsKey(ride.getID())) {
loaded.notify(); loaded.notify();
Thread.sleep(Main.WAIT_SPEED);
loaded.wait(); loaded.wait();
} }
@ -145,7 +143,7 @@ public class BridgeMock extends BridgeServlet {
// ID is final/threadsafe // ID is final/threadsafe
while(!(booked.containsKey(ride.getID()))){ while(!(booked.containsKey(ride.getID()))){
Thread.sleep(Main.WAIT_SPEED);
} }
synchronized (booked) { synchronized (booked) {

@ -5,7 +5,7 @@ import actor.UserMock;
public class Main { public class Main {
final public static int WAIT_SPEED = 0;

Loading…
Cancel
Save