(method, input_data, output_data)
| 2689 | comp = ZstdCompressor() |
| 2690 | output = [comp.compress(input, ZstdCompressor.FLUSH_BLOCK)] |
| 2691 | def run_method(method, input_data, output_data): |
| 2692 | res = method(input_data, ZstdCompressor.FLUSH_BLOCK) |
| 2693 | if res: |
| 2694 | output_data.append(res) |
| 2695 | threads = [] |
| 2696 | |
| 2697 | for i in range(num_threads): |