Wait for results to be ready

Author: mlouhivu

demos/pool-map.py

@@ -12,6 +12,8 @@ def f(x):
 # non-blocking alternative
 result = pool.map_async(f, range(10))
 while not result.ready():
+    print("waiting...")
     time.sleep(1)
+
 print(result.get())
 

demos/pool.py

@@ -1,4 +1,5 @@
 from multiprocessing import Pool
+import time
 
 def f(x):
     return x**2
@@ -11,5 +12,9 @@ def f(x):
 
 # Non-blocking execution "in the background"
 result = pool.apply_async(f, (12,))
+while not result.ready():
+    print("waiting...")
+    time.sleep(1)
+
 print(result.get(timeout=1))