diff options
author | Damien George <damien.p.george@gmail.com> | 2016-04-19 17:03:26 +0000 |
---|---|---|
committer | Damien George <damien.p.george@gmail.com> | 2016-06-28 11:09:31 +0100 |
commit | ed36632c6cc227206994cf68b4a4afec2b694e49 (patch) | |
tree | bc7b3c4f7e5882dada6bce99e8dd54517c1f8284 /tests/thread/thread_lock3.py | |
parent | f2892bd77da5f7adbad3d83bb6e0898af224975b (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.py | 27 |
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 |