Change files for blog example

Author: Rperry2174

examples/python/Dockerfile

@@ -4,6 +4,10 @@ WORKDIR /usr/src/app
 
 COPY --from=pyroscope/pyroscope:latest /usr/bin/pyroscope /usr/bin/pyroscope
 COPY main.py ./main.py
+COPY util.py ./util.py
+COPY __init__.py ./__init__.py
+COPY fast_package ./fast_package
+COPY slow_module ./slow_module
 
 ENV PYROSCOPE_APPLICATION_NAME=simple.python.app
 ENV PYROSCOPE_SERVER_ADDRESS=http://pyroscope:4040/

examples/python/__init__.py

@@ -11,3 +11,4 @@ services:
     build: .
     cap_add:
       - SYS_PTRACE
+

examples/python/docker-compose.yml

@@ -0,0 +1,4 @@
+from util import work
+
+def fast_function(speed):
+  work(speed)

examples/python/fast_package/__init__.py

@@ -1,15 +1,59 @@
-def work(n):
-  i = 0
-  while i < n:
-    i += 1
+import time
+import threading
+from fast_package.fast_file import fast_function
+from slow_module.slow_file import slow_function
 
-def fast_function():
-  work(20000)
-
-def slow_function():
-  work(80000)
+DURATION = 60 * 10 # ten minutes
 
 if __name__ == "__main__":
-  while True:
-    fast_function()
-    slow_function()
+  t_start = time.time()
+  t_end = time.time() + DURATION
+
+  print(f'yoyoy Application started at: {t_start}')
+  while time.time() < t_end:
+    threads = list()
+    fast_thread = threading.Thread(target=fast_function, args=(25000,))
+    slow_thread = threading.Thread(target=slow_function, args=(8000,))
+
+    threads.append(fast_thread)
+    fast_thread.start()
+
+    threads.append(slow_thread)
+    slow_thread.start()
+
+    for index, thread in enumerate(threads):
+        # print("Main    : before joining thread %d.", index)
+        thread.join()
+        # print("Main    : thread %d done", index)
+
+  print(f'yoyoy Application ended at: {t_end}')
+
+  print(f'Switching fast and slow around.....')
+  time.sleep(60)
+  print(f'Switching fast and slow around.....')
+
+  t_start = time.time()
+  t_end = time.time() + DURATION
+
+  print(f'yoyoy Application started at: {t_start}')
+  while time.time() < t_end:
+    threads = list()
+    fast_thread = threading.Thread(target=fast_function, args=(25000,))
+    slow_thread = threading.Thread(target=slow_function, args=(75000,))
+
+    threads.append(fast_thread)
+    fast_thread.start()
+
+    threads.append(slow_thread)
+    slow_thread.start()
+
+    for index, thread in enumerate(threads):
+        # print("Main    : before joining thread %d.", index)
+        thread.join()
+        # print("Main    : thread %d done", index)
+
+  print(f'yoyoy Application ended at: {t_end}')
+
+
+
+

examples/python/fast_package/fast_file.py

@@ -0,0 +1,4 @@
+from util import work
+
+def slow_function(speed):
+  work(speed)

examples/python/main.py

@@ -0,0 +1,4 @@
+def work(n):
+  i = 0
+  while i < n:
+    i += 1