import threading
import time
def worker(num, sleep_time):
"""
简单的工作函数,接受一个数字和睡眠时间
然后打印这个数字和睡眠时间,并在屏幕上显示
"""
print(f"Worker {num} starting")
time.sleep(sleep_time)
print(f"Worker {num} finished in {sleep_time} seconds")
def main():
# 创建一个线程列表
threads = []
# 创建并启动线程
for i in range(5):
t = threading.Thread(target=worker, args=(i, i))
t.start()
threads.append(t)
# 等待所有线程完成
for t in threads:
t.join()
# 如果这个模块是作为主程序运行的,则执行main函数
if __name__ == "__main__":
main()
这段代码创建了一个名为worker
的函数,这个函数将作为线程的入口函数。main
函数创建了一个线程列表,然后为数字0到4创建并启动了线程,每个线程都会调用worker
函数,并且每个线程的睡眠时间都与其编号相同。最后,主函数等待所有线程完成。这个例子展示了如何在Python中使用threading模块来实现并行操作。