diff options
| author | Damien George <damien.p.george@gmail.com> | 2016-04-25 18:16:43 +0000 |
|---|---|---|
| committer | Damien George <damien.p.george@gmail.com> | 2016-06-28 11:28:49 +0100 |
| commit | dcc7c5bd891c5da69f430ab93c24aa2567521b71 (patch) | |
| tree | d6184d91e9dab43c817e6e249d11f07ef36b1bd4 /tests/thread/thread_gc1.py | |
| parent | c93d9caa8b8be81f7e6faf9f2ca2ad16d4942ab8 (diff) | |
tests/thread: Add tests for running GC within a thread, and heap stress.
Diffstat (limited to 'tests/thread/thread_gc1.py')
| -rw-r--r-- | tests/thread/thread_gc1.py | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/tests/thread/thread_gc1.py b/tests/thread/thread_gc1.py new file mode 100644 index 000000000..8dcbf7e07 --- /dev/null +++ b/tests/thread/thread_gc1.py @@ -0,0 +1,34 @@ +# test that we can run the garbage collector within threads +# +# MIT license; Copyright (c) 2016 Damien P. George on behalf of Pycom Ltd + +import gc +import _thread + +def thread_entry(n): + # allocate a bytearray and fill it + data = bytearray(i for i in range(256)) + + # do some work and call gc.collect() a few times + for i in range(n): + for i in range(len(data)): + data[i] = data[i] + gc.collect() + + # print whether the data remains intact and indicate we are finished + with lock: + print(list(data) == list(range(256))) + global n_finished + n_finished += 1 + +lock = _thread.allocate_lock() +n_thread = 4 +n_finished = 0 + +# spawn threads +for i in range(n_thread): + _thread.start_new_thread(thread_entry, (10,)) + +# busy wait for threads to finish +while n_finished < n_thread: + pass |
