python多线程菜鸟教程,python 多线程有几种实现方法

　　本文主要介绍Python中的多线程例子，一个CPU，把时间切成块，CPU轮流处理一件事，到了指定的时间片再处理下一件事。更多相关内容，请参考以下文章了解详情。

　　00-1010 1.Python 2中显示当前线程信息的属性和方法。添加一个线程3。线程4中的join函数。使用队列存储线程5的结果。螺纹锁前言：

　　多线程简单理解就是：,的一个CPU也就是单核，把时间分割成块，CPU轮流一次处理一件事，然后在指定时间处理下一件事。

目录

　　#编码：utf-8

　　#导入线程包

　　导入线程

　　if __name__==__main__:

　　Print(当前活动线程数，threading.active_count())

　　Print(显示当前所有线程的具体信息，threading.enumerate())

　　Print(当前线程的信息显示，threading.current_thread())

　　效果图：

1.python中显示当前线程信息的属性和方法

　　#编码：utf-8

　　导入线程

　　导入时间

　　定义工单1():

　　#让这个线程再执行几秒钟

　　时间.睡眠(5)

　　print( T1的数目是%s % threading.current_thread())

　　if __name__==__main__:

　　#创建一个新线程

　　新线程=线程。线程(target=job1，name=T1 )

　　#开始一个新线程

　　new_thread.start()

　　Print(当前线程数为，threading.active_count())

　　Print(所有线程的特定信息，threading.enumerate())

　　Print(当前线程详细信息，threading.current_thread())

　　效果图：

2.添加一个线程

　　(1)预计执行线程1，然后全部完成…将输出…“理想很丰满，但现实不是这样的”

　　#编码：utf-8

　　导入线程

　　导入时间

　　定义工单1():

　　打印(“T1开始”)

　　对于范围(5):中的I

　　时间.睡眠(1)

　　打印(一)

　　打印(“T1完成”)

　　定义主():

　　#创建一个新线程

　　新线程=线程。线程(target=job1，name=T1 )

　　#开始一个新线程

　　new_thread.start()

　　打印(全部完成.)

　　if __name__==__main__:

　　主()

　　效果图：

　　(2)为了满足我们的期望，我们使用join函数来阻塞T1线程。屏蔽join功能是什么意思？即哪个线程使用join函数。这个线程在执行的时候，后面的线程程序是不能执行的。直到所有被阻塞的线程都被执行后才能执行！

　　#编码：utf-8

　　导入线程

　　导入时间

　　定义工单1():

　　打印(“T1开始”)

　　对于范围(5):中的I

　　时间.睡眠(1)

　　打印(一)

　　p

　　rint("T1 finish")

　　def main():

　　 # 新创建一个线程

　　 new_thread = threading.Thread(target=job1, name="T1")

　　 # 启动新线程

　　 new_thread.start()

　　 # 阻塞这个T1线程

　　 new_thread.join()

　　 print("All done...")

　　if __name__ == "__main__":

　　 main()

　　效果图：

4.使用Queue存储线程的结果

　　线程的执行结果，无法通过return进行返回，使用Queue存储。

# coding:utf-8
　　import threading
　　from queue import Queue
　　"""
　　 Queue的使用
　　"""
　　def job(l, q):
　　 for i in range(len(l)):
　　 l[i] = l[i] ** 2
　　 q.put(l)
　　def multithreading():
　　 # 创建队列
　　 q = Queue()
　　 # 线程列表
　　 threads = []
　　 # 二维列表
　　 data = [[1, 2, 3], [4, 5, 6], [7, 8, 9], [6, 6, 6]]
　　 for i in range(4):
　　 t = threading.Thread(target=job, args=(data[i], q))
　　 t.start()
　　 threads.append(t)
　　 # 对所有线程进行阻塞
　　 for thread in threads:
　　 thread.join()
　　 results = []
　　 # 将新队列中的每个元素挨个放到结果列表中
　　 for _ in range(4):
　　 results.append(q.get())
　　 print(results)
　　if __name__ == "__main__":
　　 multithreading()

　　效果图：

5.线程锁lock

　　当同时启动多个线程时，各个线程之间会互相抢占计算资源，会造成程序混乱。

　　举个栗子：

　　当我们在选课系统选课时，当前篮球课还有2个名额，我们三个人去选课。

　　选课顺序为stu1 stu2 stu3,应该依次打印他们三个的选课过程，但是现实情况却是：

# coding:utf-8
　　import threading
　　import time
　　def stu1():
　　 print("stu1开始选课")
　　 global course
　　 if course > 0:
　　 course -= 1
　　 time.sleep(2)
　　 print("stu1选课成功,现在篮球课所剩名额为%d" % course)
　　 else:
　　 time.sleep(2)
　　 print("stu1选课失败，篮球课名额为0，请选择其他课程")
　　def stu2():
　　 print("stu2开始选课")
　　 global course
　　 if course > 0:
　　 course -= 1
　　 time.sleep(2)
　　 print("stu2选课成功,现在篮球课所剩名额为%d" % course)
　　 else:
　　 time.sleep(2)
　　 print("stu2选课失败，篮球课名额为0，请选择其他课程")
　　def stu3():
　　 print("stu3开始选课")
　　 global course
　　 if course > 0:
　　 course -= 1
　　 time.sleep(2)
　　 print("stu3选课成功")
　　 print("篮球课所剩名额为%d" %course)
　　 else:
　　 time.sleep(2)
　　 print("stu3选课失败，篮球课名额为0，请选择其他课程")
　　if __name__ == "__main__":
　　 # 篮球课名额
　　 course = 2
　　 T1 = threading.Thread(target=stu1, name="T1")
　　 T2 = threading.Thread(target=stu2, name="T2")
　　 T3 = threading.Thread(target=stu3, name="T3")
　　 T1.start()
　　 T2.start()
　　 T3.start()

　　效果图：

　　为了解决这种情况，我们使用lock线程同步锁，在线程并发执行时，保证每个线程执行的原子性。有效防止了共享统一数据时，线程并发执行的混乱。

　　改进的代码如下：

# coding:utf-8
　　import threading
　　import time
　　def stu1():
　　 global lock
　　 lock.acquire()
　　 print("stu1开始选课")
　　 global course
　　 if course > 0:
　　 course -= 1
　　 time.sleep(2)
　　 print("stu1选课成功,现在篮球课所剩名额为%d" % course)
　　 else:
　　 time.sleep(2)
　　 print("stu1选课失败，篮球课名额为0，请选择其他课程")
　　 lock.release()
　　def stu2():
　　 global lock
　　 lock.acquire()
　　 print("stu2开始选课")
　　 global course
　　 if course > 0:
　　 course -= 1
　　 print("stu2选课成功,现在篮球课所剩名额为%d" % course)
　　 else:
　　 time.sleep(1)
　　 print("stu2选课失败，篮球课名额为0，请选择其他课程")
　　 lock.release()
　　def stu3():
　　 global lock
　　 lock.acquire()
　　 print("stu3开始选课")
　　 global course
　　 if course > 0:
　　 course -= 1
　　 time.sleep(1)
　　 print("stu3选课成功,现在篮球课所剩名额为%d" % course)
　　 else:
　　 time.sleep(1)
　　 print("stu3选课失败，篮球课名额为0，请选择其他课程")
　　 lock.release()
　　if __name__ == "__main__":
　　 # 篮球课名额
　　 course = 2
　　 # 创建同步锁
　　 lock = threading.Lock()
　　 T1 = threading.Thread(target=stu1, name="T1")
　　 T2 = threading.Thread(target=stu2, name="T2")
　　 T3 = threading.Thread(target=stu3, name="T3")
　　 T1.start()
　　 T2.start()
　　 T3.start()

　　效果图：

　　到此这篇关于Python中的多线程实例(简单易懂)的文章就介绍到这了,更多相关Python多线程内容请搜索盛行IT软件开发工作室以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT软件开发工作室！

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。