Make experiments folder

Author: samuell

experiments/string_processing_pipeline.py

@@ -0,0 +1,100 @@
+import asyncio
+
+
+def main():
+    loop = asyncio.get_event_loop()
+
+    # Initialize components
+    hisayer = HiSayer()
+    loop.create_task(hisayer.run())
+
+    splitter = StringSplitter()
+    loop.create_task(splitter.run())
+
+    lowercaser = LowerCaser()
+    loop.create_task(lowercaser.run())
+
+    uppercaser = UpperCaser()
+    loop.create_task(uppercaser.run())
+
+    stringjoiner = StringJoiner()
+    loop.create_task(stringjoiner.run())
+
+    printer = Printer()
+    loop.create_task(printer.run())
+
+    # Connect network
+    splitter.in_lines = hisayer.out_lines
+    lowercaser.in_lines = splitter.out_leftpart
+    uppercaser.in_lines = splitter.out_rightpart
+    stringjoiner.in_leftpart = lowercaser.out_lines
+    stringjoiner.in_rightpart = uppercaser.out_lines
+    printer.in_lines = stringjoiner.out_lines
+
+    # Run the full event loop
+    loop.run_until_complete(printer.run())
+
+
+class HiSayer:
+    out_lines = asyncio.Queue()
+
+    async def run(self):
+        for i in range(20):
+            await self.out_lines.put(f"Hi hi for the {i+1}:th time...")
+
+
+class StringSplitter:
+    in_lines = asyncio.Queue()
+    out_leftpart = asyncio.Queue()
+    out_rightpart = asyncio.Queue()
+
+    async def run(self):
+        while not self.in_lines.empty():
+            s = await self.in_lines.get()
+            await self.out_leftpart.put(s[: int(len(s) / 2)])
+            await self.out_rightpart.put(s[int(len(s) / 2) :])
+
+
+class LowerCaser:
+    in_lines = asyncio.Queue()
+    out_lines = asyncio.Queue()
+
+    async def run(self):
+        while not self.in_lines.empty():
+            s = await self.in_lines.get()
+            await self.out_lines.put(s.lower())
+
+
+class UpperCaser:
+    in_lines = asyncio.Queue()
+    out_lines = asyncio.Queue()
+
+    async def run(self):
+        while not self.in_lines.empty():
+            s = await self.in_lines.get()
+            await self.out_lines.put(s.upper())
+
+
+class StringJoiner:
+    in_leftpart = asyncio.Queue()
+    in_rightpart = asyncio.Queue()
+    out_lines = asyncio.Queue()
+
+    async def run(self):
+        while not self.in_leftpart.empty() or not self.in_rightpart.empty():
+            leftpart = await self.in_leftpart.get()
+            rightpart = await self.in_rightpart.get()
+            await self.out_lines.put(f"{leftpart}{rightpart}")
+
+
+class Printer:
+    in_lines = asyncio.Queue()
+
+    async def run(self):
+        while not self.in_lines.empty():
+            s = await self.in_lines.get()
+            print(f"Printer got line: {s}")
+
+
+if __name__ == "__main__":
+    main()