From 651c2b76ff3db39cefd1542d6f4c19d8686dfb85 Mon Sep 17 00:00:00 2001 From: Martin Date: Sun, 22 Dec 2019 17:29:25 +0100 Subject: Implement executor (#65) --- .../edu/mimuw/cloudatlas/agent/ExecutorTest.java | 54 ++++++++++++++++++++++ 1 file changed, 54 insertions(+) create mode 100644 src/test/java/pl/edu/mimuw/cloudatlas/agent/ExecutorTest.java (limited to 'src/test') diff --git a/src/test/java/pl/edu/mimuw/cloudatlas/agent/ExecutorTest.java b/src/test/java/pl/edu/mimuw/cloudatlas/agent/ExecutorTest.java new file mode 100644 index 0000000..445a5b4 --- /dev/null +++ b/src/test/java/pl/edu/mimuw/cloudatlas/agent/ExecutorTest.java @@ -0,0 +1,54 @@ +package pl.edu.mimuw.cloudatlas.agent; + +import org.junit.Test; +import static org.junit.Assert.*; + +import pl.edu.mimuw.cloudatlas.agent.message.AgentMessage; +import pl.edu.mimuw.cloudatlas.agent.message.AgentMessage.AgentModule; + +public class ExecutorTest { + public class MessageCounterModule extends Module { + public int counter = 0; + public void handle(AgentMessage m) { + counter++; + } + } + + @Test + public void testDoesntExecuteWhenNoMessages() throws Exception { + MessageCounterModule module = new MessageCounterModule(); + Executor executor = new Executor(module); + Thread thread = new Thread(executor); + thread.start(); + Thread.sleep(100); + thread.interrupt(); + assertEquals(0, module.counter); + } + + @Test + public void testExecutesHandlerOnce() throws Exception { + MessageCounterModule module = new MessageCounterModule(); + Executor executor = new Executor(module); + executor.addMessage(new AgentMessage("", AgentModule.UDP, 0) {}); + Thread thread = new Thread(executor); + thread.start(); + Thread.sleep(100); + thread.interrupt(); + assertEquals(1, module.counter); + } + + @Test + public void testExecutesHandlerMultipleTimes() throws Exception { + MessageCounterModule module = new MessageCounterModule(); + Executor executor = new Executor(module); + executor.addMessage(new AgentMessage("", AgentModule.UDP, 0) {}); + executor.addMessage(new AgentMessage("", AgentModule.UDP, 0) {}); + Thread thread = new Thread(executor); + thread.start(); + Thread.sleep(100); + executor.addMessage(new AgentMessage("", AgentModule.UDP, 0) {}); + Thread.sleep(100); + thread.interrupt(); + assertEquals(3, module.counter); + } +} -- cgit v1.2.3