summaryrefslogtreecommitdiff
path: root/tests/thread/thread_lock3.py
diff options
context:
space:
mode:
authorDamien George <damien.p.george@gmail.com>2016-04-19 17:03:26 +0000
committerDamien George <damien.p.george@gmail.com>2016-06-28 11:09:31 +0100
commited36632c6cc227206994cf68b4a4afec2b694e49 (patch)
treebc7b3c4f7e5882dada6bce99e8dd54517c1f8284 /tests/thread/thread_lock3.py
parentf2892bd77da5f7adbad3d83bb6e0898af224975b (diff)
tests: Add tests for _thread module.
Includes functionality and stress tests.
Diffstat (limited to 'tests/thread/thread_lock3.py')
-rw-r--r--tests/thread/thread_lock3.py27
1 files changed, 27 insertions, 0 deletions
diff --git a/tests/thread/thread_lock3.py b/tests/thread/thread_lock3.py
new file mode 100644
index 000000000..607898dad
--- /dev/null
+++ b/tests/thread/thread_lock3.py
@@ -0,0 +1,27 @@
+# test thread coordination using a lock object
+#
+# MIT license; Copyright (c) 2016 Damien P. George on behalf of Pycom Ltd
+
+import _thread
+
+lock = _thread.allocate_lock()
+n_thread = 10
+n_finished = 0
+
+def thread_entry(idx):
+ global n_finished
+ while True:
+ with lock:
+ if n_finished == idx:
+ break
+ print('my turn:', idx)
+ with lock:
+ n_finished += 1
+
+# spawn threads
+for i in range(n_thread):
+ _thread.start_new_thread(thread_entry, (i,))
+
+# busy wait for threads to finish
+while n_finished < n_thread:
+ pass