(
json, worker, data, number_of_threads=12, number_of_json_encodings=100
)
| 4 | |
| 5 | |
| 6 | def encode_json_helper( |
| 7 | json, worker, data, number_of_threads=12, number_of_json_encodings=100 |
| 8 | ): |
| 9 | worker_threads = [] |
| 10 | barrier = Barrier(number_of_threads) |
| 11 | for index in range(number_of_threads): |
| 12 | worker_threads.append( |
| 13 | Thread(target=worker, args=[barrier, data, index]) |
| 14 | ) |
| 15 | for t in worker_threads: |
| 16 | t.start() |
| 17 | for ii in range(number_of_json_encodings): |
| 18 | json.dumps(data) |
| 19 | data.clear() |
| 20 | for t in worker_threads: |
| 21 | t.join() |
| 22 | |
| 23 | |
| 24 | class MyMapping(dict): |
no test coverage detected
searching dependent graphs…