| | |
|---|
| | | time.sleep(2) |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | p1, p2 = multiprocessing.Pipe() |
|---|
| | | serverProcess = multiprocessing.Process(target=run_process_1, args=(p1,)) |
|---|
| | | jueJinProcess = multiprocessing.Process(target=run_process_2, args=(p2,)) |
|---|
| | | serverProcess.start() |
|---|
| | | jueJinProcess.start() |
|---|
| | | def test1(params): |
|---|
| | | time.sleep(1) |
|---|
| | | print("执行结束", params) |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=20) |
|---|
| | | thread_pool.submit(lambda: test1("123123")) |
|---|
| | | thread_pool.submit(lambda: test1("123123")) |
|---|
| | | thread_pool.submit(lambda: test1("123123")) |
|---|
| | | thread_pool.submit(lambda: test1("123123")) |
|---|
| | | while True: |
|---|
| | | time.sleep(2) |
|---|
| | | running_count = 0 |
|---|
| | | for future in thread_pool._threads: |
|---|
| | | if future.is_alive(): |
|---|
| | | running_count += 1 |
|---|
| | | print(running_count) |
|---|
| | | time.sleep(1) |
|---|
