本博文将从单线程、子函数中使用多线程和main中使用多线程进行示例代码演示。
1、单线程
示例代码：
import time
from queue import Queue
def task_func(queue):
while queue.qsize() > 0:
x = queue.get()
print(f"num: {x}")
time.sleep(0.1)
def single_thead():
queue = Queue()
for i in range(100):
queue.put(i)
task_func(queue)
if __name__ == '__main__':
start_time = time.time()
single_thead()
print("主程序执行结束！")
print("程序执行耗时：", time.time() - start_time)
运行结果：
2、子函数使用多线程
示例代码：
import time
import threading
from queue import Queue
def task_func(queue):
while queue.qsize() > 0:
x = queue.get()
print(f"num: {x}")
time.sleep(0.1)
def multi_thead():
queue = Queue()
for i in range(100):
queue.put(i)
thread_list = []
for i in range(5):
thread = threading.Thread(target=task_func, args=(queue, ))
thread.start()
thread_list.append(thread)
for thread in thread_list:
thread.join()
if __name__ == '__main__':
start_time = time.time()
multi_thead()
print("主程序执行结束！")
print("程序执行耗时：", time.time() - start_time)
运行结果：
3、main主函数中使用多线程
示例代码：
import time
import threading
from queue import Queue
def task_func():
global queue
while queue.qsize() > 0:
x = queue.get()
print(f"num: {x}")
time.sleep(0.1)
if __name__ == '__main__':
start_time = time.time()
queue = Queue()
for i in range(100):
queue.put(i)
thread_list = []
for i in range(5):
thread = threading.Thread(target=task_func)
thread.start()
thread_list.append(thread)
for thread in thread_list:
thread.join()
print("主程序执行结束！")
print("程序执行耗时：", time.time() - start_time)
运行结果：
综上所述：在mian主函数中使用多线程和在子函数中使用多线程效果是类似的。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/142772.html
