()
| 34 | |
| 35 | |
| 36 | def tutorial_multi_pipeline(): |
| 37 | pipeline1, pipeline2 = GPipeline(), GPipeline() |
| 38 | |
| 39 | config = UThreadPoolConfig() |
| 40 | config.default_thread_size = 4 |
| 41 | config.max_thread_size = 4 |
| 42 | config.monitor_enable = False |
| 43 | pool = UThreadPool(True, config) |
| 44 | |
| 45 | pipeline1.setSharedThreadPool(pool) |
| 46 | pipeline2.setSharedThreadPool(pool) |
| 47 | |
| 48 | result1 = async_pipeline_1(pipeline1) |
| 49 | result2 = async_pipeline_2(pipeline2) |
| 50 | |
| 51 | result1.wait() |
| 52 | result2.wait() |
| 53 | |
| 54 | |
| 55 | if __name__ == '__main__': |
no test coverage detected