请写一个线程池处理并发示例
时间: 2023-02-09 17:10:44 浏览: 104
线程池并发测试例子
```python
import threading
from queue import Queue
import time
# 自定义任务函数
def do_something(index):
time.sleep(index)
print(f"Task {index} finished.")
# 创建线程池
pool = []
for i in range(5):
t = threading.Thread(target=do_something, args=(i,))
pool.append(t)
# 开启线程
for t in pool:
t.start()
# 等待线程结束
for t in pool:
t.join()
print("All tasks finished.")
```
在这个示例中,我们创建了一个大小为5的线程池,并在每个线程中运行自定义函数`do_something`。在这个函数中,我们让线程休眠了相应的时间,然后打印出“任务x已完成”。最后,我们启动所有线程并等待它们全部结束。
阅读全文