updates

Author: jsheedy

…g/integrate/cheap-hack/integrate_main.py …g/integrate/sequential/integrate_main.pyExamples/week-07-threading-and-multiprocessing/integrate/cheap-hack/integrate_main.py renamed to Examples/week-07-threading-and-multiprocessing/integrate/sequential/integrate_main.py Examples/week-07-threading-and-multiprocessing/integrate/cheap-hack/integrate_main.py renamed to Examples/week-07-threading-and-multiprocessing/integrate/sequential/integrate_main.py

@@ -14,7 +14,7 @@ def func():
 threads = []
 # with enough threads, there's sufficient overhead to cause a race
 # condition
-for i in xrange(10000):
+for i in xrange(20000):
     thread = threading.Thread(target=func)
     threads.append(thread)
     thread.start()

Examples/week-07-threading-and-multiprocessing/race_condition.py

@@ -0,0 +1,35 @@
+#!/usr/bin/env python3
+
+import os
+import sys
+from urllib.request import urlopen
+import asyncio
+
+sys.path.append(os.path.join(os.path.dirname(__file__), ".."))
+
+# from decorators.decorators import timer
+
+# @timer
+
+results = asyncio.Queue()
+url = "http://localhost:37337"
+
+@asyncio.coroutine
+def producer():
+    conn = urlopen(url)
+    result = conn.read()
+    return result
+
+@asyncio.coroutine
+def worker():
+    result = yield from producer()
+    results.put(result)
+
+loop = asyncio.get_event_loop()
+
+number_of_requests = 100
+
+for i in range(number_of_requests):
+    loop.run_until_complete(worker())
+
+print( "made %d requests" % number_of_requests)

Examples/week-07-threading-and-multiprocessing/server/client-asyncio.py

@@ -15,15 +15,15 @@ def threading_integrate(f, a, b, N, thread_count=2):
     """break work into two chunks"""
     N_chunk = int(float(N) / thread_count)
     dx = float(b-a) / thread_count
-    
+
     results = Queue.Queue()
 
     def worker(*args):
         results.put(integrate(*args))
 
     threads = []
     for i in xrange(thread_count):
-        x0 = dx*i 
+        x0 = dx*i
         x1 = x0 + dx
         thread = threading.Thread(target=worker, args=(f, x0, x1, N_chunk))
         thread.start()