Merge pull request #105 from pycom/fix_thread_tests

sleep in main thread to yield

Author: Xykon

tests/thread/mutate_bytearray.py

@@ -3,6 +3,7 @@
 # MIT license; Copyright (c) 2016 Damien P. George on behalf of Pycom Ltd
 
 import _thread
+import time
 
 # the shared bytearray
 ba = bytearray()
@@ -34,12 +35,11 @@ def th(n, lo, hi):
 
 # busy wait for threads to finish
 while n_finished < n_thread:
-    pass
+    time.sleep(0.01)
 
 # check bytearray has correct contents
 print(len(ba))
 count = [0 for _ in range(256)]
 for b in ba:
     count[b] += 1
 print(count)
-

tests/thread/mutate_dict.py

@@ -3,6 +3,7 @@
 # MIT license; Copyright (c) 2016 Damien P. George on behalf of Pycom Ltd
 
 import _thread
+import time
 
 # the shared dict
 di = {'a':'A', 'b':'B', 'c':'C', 'd':'D'}
@@ -36,7 +37,7 @@ def th(n, lo, hi):
 
 # busy wait for threads to finish
 while n_finished < n_thread:
-    pass
+    time.sleep(0.01)
 
 # check dict has correct contents
 print(sorted(di.items()))

tests/thread/mutate_instance.py

@@ -3,6 +3,7 @@
 # MIT license; Copyright (c) 2016 Damien P. George on behalf of Pycom Ltd
 
 import _thread
+import time
 
 # the shared user class and instance
 class User:
@@ -35,7 +36,7 @@ def th(n, lo, hi):
 
 # busy wait for threads to finish
 while n_finished < n_thread:
-    pass
+    time.sleep(0.01)
 
 # check user instance has correct contents
 print(user.a, user.b, user.c)

tests/thread/mutate_list.py

@@ -3,6 +3,7 @@
 # MIT license; Copyright (c) 2016 Damien P. George on behalf of Pycom Ltd
 
 import _thread
+import time
 
 # the shared list
 li = list()
@@ -37,7 +38,7 @@ def th(n, lo, hi):
 
 # busy wait for threads to finish
 while n_finished < n_thread:
-    pass
+    time.sleep(0.01)
 
 # check list has correct contents
 li.sort()

tests/thread/mutate_set.py

@@ -3,6 +3,7 @@
 # MIT license; Copyright (c) 2016 Damien P. George on behalf of Pycom Ltd
 
 import _thread
+import time
 
 # the shared set
 se = set([-1, -2, -3, -4])
@@ -31,7 +32,7 @@ def th(n, lo, hi):
 
 # busy wait for threads to finish
 while n_finished < n_thread:
-    pass
+    time.sleep(0.01)
 
 # check set has correct contents
 print(sorted(se))

tests/thread/stress_create.py

@@ -15,7 +15,7 @@ def thread_entry(n):
         _thread.start_new_thread(thread_entry, (thread_num,))
         thread_num += 1
     except MemoryError:
-        pass
+        time.sleep(0.01)
 
 # wait for the last threads to terminate
 time.sleep(1)

tests/thread/stress_recurse.py

@@ -3,6 +3,7 @@
 # MIT license; Copyright (c) 2016 Damien P. George on behalf of Pycom Ltd
 
 import _thread
+import time
 
 def foo():
     foo()
@@ -21,5 +22,5 @@ def thread_entry():
 
 # busy wait for thread to finish
 while not finished:
-    pass
+    time.sleep(0.01)
 print('done')

tests/thread/thread_exc1.py

@@ -3,6 +3,7 @@
 # MIT license; Copyright (c) 2016 Damien P. George on behalf of Pycom Ltd
 
 import _thread
+import time
 
 def foo():
     raise ValueError
@@ -26,5 +27,5 @@ def thread_entry():
 
 # busy wait for threads to finish
 while n_finished < n_thread:
-    pass
+    time.sleep(0.01)
 print('done')

tests/thread/thread_gc1.py

@@ -4,6 +4,7 @@
 
 import gc
 import _thread
+import time
 
 def thread_entry(n):
     # allocate a bytearray and fill it
@@ -31,4 +32,4 @@ def thread_entry(n):
 
 # busy wait for threads to finish
 while n_finished < n_thread:
-    pass
+    time.sleep(0.01)

tests/thread/thread_ident1.py

@@ -3,6 +3,7 @@
 # MIT license; Copyright (c) 2016 Damien P. George on behalf of Pycom Ltd
 
 import _thread
+import time
 
 def thread_entry():
     tid = _thread.get_ident()
@@ -17,5 +18,5 @@ def thread_entry():
 _thread.start_new_thread(thread_entry, ())
 
 while not finished:
-    pass
+    time.sleep(0.01)
 print('done')