Merge branch 'master' of https://github.com/talkpython/async-techniques-python-course

Author: mikeckennedy

.gitignore

@@ -134,3 +134,9 @@ src/10-async-web/.idea/webResources.xml
 src/10-async-web/.idea/workspace.xml
 src/10-async-web/.idea/dictionaries/mkennedy.xml
 Project_Default.xml
+src/11-cython/.idea/11-cython.iml
+src/11-cython/.idea/misc.xml
+src/11-cython/.idea/modules.xml
+src/11-cython/.idea/workspace.xml
+greeter.c
+math_core.c

src/11-cython/.idea/dictionaries/screencaster.xml

@@ -0,0 +1,3 @@
+def greet(name: str):
+    print("Hello {}".format(name))
+    print(" ** Running from {} **".format(__file__))

src/11-cython/.idea/vcs.xml

@@ -0,0 +1,10 @@
+import greeter
+
+
+def main():
+    name = input("What is your name? ")
+    greeter.greet(name)
+
+
+if __name__ == '__main__':
+    main()

src/11-cython/hello_world/greeter.pyx

@@ -0,0 +1,6 @@
+from distutils.core import setup
+from Cython.Build import cythonize
+
+setup(
+    ext_modules=cythonize("greeter.pyx")
+)

src/11-cython/hello_world/program.py

@@ -0,0 +1,43 @@
+import datetime
+import math_core
+from threading import Thread
+import multiprocessing
+
+
+def main():
+    math_core.do_math(1)
+
+    print("Doing math on {:,} processors.".format(multiprocessing.cpu_count()))
+
+    processor_count = multiprocessing.cpu_count()
+    threads = []
+    for n in range(1, processor_count + 1):
+        threads.append(Thread(target=math_core.do_math,
+                              args=(3_000_000 * (n - 1) / processor_count,
+                                    3_000_000 * n / processor_count),
+                              daemon=True)
+                       )
+
+    t0 = datetime.datetime.now()
+    [t.start() for t in threads]
+
+    [t.join() for t in threads]
+    # math_core.do_math(num=300_000)
+
+    dt = datetime.datetime.now() - t0
+    print("Done in {:,.2f} sec. (factor: {:,.2f}x)".format(
+        dt.total_seconds(),
+        0.80 / dt.total_seconds())
+    )
+
+
+# def do_math(start=0, num=10):
+#     pos = start
+#     k_sq = 1000 * 1000
+#     while pos < num:
+#         pos += 1
+#         math.sqrt((pos - k_sq) * (pos - k_sq))
+
+
+if __name__ == '__main__':
+    main()

src/11-cython/hello_world/setup.py

@@ -0,0 +1,25 @@
+import datetime
+import math
+
+
+def main():
+    do_math(1)
+
+    t0 = datetime.datetime.now()
+
+    do_math(num=3_000_000)
+
+    dt = datetime.datetime.now() - t0
+    print("Done in {:,.2f} sec.".format(dt.total_seconds()))
+
+
+def do_math(start=0, num=10):
+    pos = start
+    k_sq = 1000 * 1000
+    while pos < num:
+        pos += 1
+        dist = math.sqrt((pos - k_sq)*(pos - k_sq))
+
+
+if __name__ == '__main__':
+    main()

src/11-cython/perf/compute_cython.py

@@ -0,0 +1,44 @@
+import datetime
+import math
+import multiprocessing
+
+
+def main():
+    do_math(1)
+
+    t0 = datetime.datetime.now()
+
+    print("Doing math on {:,} processors.".format(multiprocessing.cpu_count()))
+
+    pool = multiprocessing.Pool()
+    processor_count = multiprocessing.cpu_count()
+    tasks = []
+    for n in range(1, processor_count + 1):
+        task = pool.apply_async(do_math, (30_000_000 * (n - 1) / processor_count,
+                                          30_000_000 * n / processor_count))
+        tasks.append(task)
+
+    pool.close()
+    pool.join()
+
+    dt = datetime.datetime.now() - t0
+    print("Done in {:,.2f} sec. (factor: {:,.2f}x)".format(
+        dt.total_seconds(),
+        8.54 / dt.total_seconds())
+    )
+
+
+def do_math(start=0, num=10):
+    pos = start
+    k_sq = 1000 * 1000
+    ave = 0
+    while pos < num:
+        pos += 1
+        val = math.sqrt((pos - k_sq) * (pos - k_sq))
+        ave += val / num
+
+    return int(ave)
+
+
+if __name__ == '__main__':
+    main()

src/11-cython/perf/compute_it.py

@@ -0,0 +1,43 @@
+import datetime
+import math
+from threading import Thread
+import multiprocessing
+
+
+def main():
+    do_math(1)
+
+    t0 = datetime.datetime.now()
+
+    # do_math(num=30000000)
+    print("Doing math on {:,} processors.".format(multiprocessing.cpu_count()))
+
+    processor_count = multiprocessing.cpu_count()
+    threads = []
+    for n in range(1, processor_count + 1):
+        threads.append(Thread(target=do_math,
+                              args=(30_000_000 * (n - 1) / processor_count,
+                                    30_000_000 * n / processor_count),
+                              daemon=True)
+                       )
+
+    [t.start() for t in threads]
+    [t.join() for t in threads]
+
+    dt = datetime.datetime.now() - t0
+    print("Done in {:,.2f} sec. (factor: {:,.2f}x)".format(
+        dt.total_seconds(),
+        8.54/dt.total_seconds())
+    )
+
+
+def do_math(start=0, num=10):
+    pos = start
+    k_sq = 1000 * 1000
+    while pos < num:
+        pos += 1
+        math.sqrt((pos - k_sq) * (pos - k_sq))
+
+
+if __name__ == '__main__':
+    main()

src/11-cython/perf/compute_multiprocessing.py

@@ -0,0 +1,12 @@
+from libc.math cimport sqrt
+
+import cython
+
+def do_math(start: cython.float = 0, num: cython.float = 10):
+    pos: cython.float = start
+    k_sq: cython.float = 1000 * 1000
+
+    with nogil:
+        while pos < num:
+            pos += 1
+            sqrt((pos - k_sq) * (pos - k_sq))

src/11-cython/perf/compute_threaded.py

@@ -0,0 +1,6 @@
+from distutils.core import setup
+from Cython.Build import cythonize
+
+setup(
+    ext_modules=cythonize("math_core.pyx")
+)

src/11-cython/perf/math_core.pyx

@@ -0,0 +1 @@
+cython