Python 多线程的实例详解

一）线程基础

1、创建线程：

thread模块提供了start_new_thread函数，用以创建线程。start_new_thread函数成功创建后还可以对其进行操作。
其函数原型：

  start_new_thread(function,atgs[,kwargs])

其参数含义如下：

    function: 在线程中执行的函数名
    args:元组形式的参数列表。
    kwargs: 可选参数，以字典的形式指定参数

方法一：通过使用thread模块中的函数创建新线程。

>>> import thread 
>>> def run(n): 
  for i in range(n): 
    print i 
 
     
>>> thread.start_new_thread(run,(4,))  #注意第二个参数一定要是元组的形式 
53840 
 
 
1 
>>>  
2 
3 
KeyboardInterrupt 
>>> thread.start_new_thread(run,(2,)) 
17840 
 
 
1 
>>>  
thread.start_new_thread(run,(),{'n':4}) 
39720 
 
 
1 
>>>  
2 
3 
thread.start_new_thread(run,(),{'n':3}) 
32480 
 
 
1 
>>>  
2 

方法二：通过继承threading.Thread创建线程

>>> import threading 
>>> class mythread(threading.Thread): 
  def __init__(self,num): 
    threading.Thread.__init__(self) 
    self.num = num 
  def run(self):        #重载run方法 
    print 'I am', self.num 
 
     
>>> t1 = mythread(1) 
>>> t2 = mythread(2) 
>>> t3 = mythread(3) 
>>> t1.start()      #运行线程t1 
I am 
>>> 1 
t2.start() 
I am 
>>> 2 
t3.start() 
I am 
>>> 3 

方法三：使用threading.Thread直接在线程中运行函数。

import threading 
>>> def run(x,y): 
  for i in range(x,y): 
    print i 
 
>>> t1 = threading.Thread(target=run,args=(15,20)) #直接使用Thread附加函数args为函数参数 
 
>>> t1.start() 
15 
>>>  
16 
17 
18 
19 

二)Thread对象中的常用方法：

1、isAlive方法：

>>> import threading 
>>> import time 
>>> class mythread(threading.Thread): 
  def __init__(self,id): 
    threading.Thread.__init__(self) 
    self.id = id 
  def run(self): 
    time.sleep(5)  #休眠5秒 
    print self.id 
 
     
>>> t = mythread(1) 
>>> def func(): 
  t.start() 
  print t.isAlive()  #打印线程状态 
 
   
>>> func() 
True 
>>> 1 

2、join方法：

原型：join([timeout]) 

    timeout: 可选参数，线程运行的最长时间

import threading 
>>> import time   #导入time模块 
>>> class Mythread(threading.Thread): 
  def __init__(self,id): 
    threading.Thread.__init__(self) 
    self.id = id 
  def run(self): 
    x = 0 
    time.sleep(20) 
    print self.id 
 
     
>>> def func(): 
  t.start() 
  for i in range(5): 
    print i 
 
     
>>> t = Mythread(2) 
>>> func() 
0 
1 
2 
3 
4 
>>> 2 
def func(): 
  t.start() 
  t.join() 
  for i in range(5): 
    print i 
 
     
>>> t = Mythread(3) 
>>> func() 
3 
0 
1 
2 
3 
4 
>>>  

3、线程名：

>>> import threading 
>>> class mythread(threading.Thread): 
  def __init__(self,threadname): 
    threading.Thread.__init__(self,name=threadname) 
  def run(self): 
    print self.getName() 
 
     
>>>  
>>> t1 = mythread('t1') 
>>> t1.start() 
t1 
>>>  

 4、setDaemon方法

在脚本运行的过程中有一个主线程，如果主线程又创建了一个子线程，那么当主线程退出时，会检验子线程是否完成。如果子线程未完成，则主线程会在等待子线程完成后退出。

当需要主线程退出时，不管子线程是否完成都随主线程退出，则可以使用Thread对象的setDaemon方法来设置。 

三）线程同步

1.简单的线程同步

使用Thread对象的Lock和RLock可以实现简单的线程同步。对于如果需要每次只有一个线程操作的数据，可以将操作过程放在acquire方法和release方法之间。如： 

# -*- coding:utf-8 -*- 
import threading 
import time 
class mythread(threading.Thread): 
  def __init__(self,threadname): 
    threading.Thread.__init__(self,name = threadname) 
  def run(self): 
    global x        #设置全局变量 
#    lock.acquire()     #调用lock的acquire方法 
    for i in range(3): 
      x = x + 1 
    time.sleep(2) 
    print x 
#    lock.release()     #调用lock的release方法 
#lock = threading.RLock()    #生成Rlock对象 
t1 = [] 
for i in range(10): 
  t = mythread(str(i)) 
  t1.append(t) 
x = 0          #将全局变量的值设为0 
for i in t1:  
  i.start() 
 
E:/study/<a href="http://lib.csdn.net/base/python" rel="external nofollow" class='replace_word' title="Python知识库" target='_blank' style='color:#df3434; font-weight:bold;'>Python</a>/workspace>xianchengtongbu.py 
3 
6 
9 
12 
15 
18 
21 
24 
27 
30 

如果将lock.acquire()和lock.release(),lock = threading.Lock()删除后保存运行脚本，结果将是输出10个30。30是x的最终值，由于x是全局变量，每个线程对其操作后进入休眠状态，在线程休眠的时候，Python解释器就执行了其他的线程而是x的值增加。当所有线程休眠结束后，x的值已被所有线修改为了30，因此输出全部为30。 

2、使用条件变量保持线程同步。

python的Condition对象提供了对复制线程同步的支持。使用Condition对象可以在某些事件触发后才处理数据。Condition对象除了具有acquire方法和release的方法外，还有wait方法、notify方法、notifyAll方法等用于条件处理。

# -*- coding:utf-8 -*- 
import threading 
class Producer(threading.Thread): 
  def __init__(self,threadname): 
    threading.Thread.__init__(self,name = threadname) 
  def run(self): 
    global x 
    con.acquire() 
    if x == 1000000: 
      con.wait() 
    #  pass 
    else: 
      for i in range(1000000): 
        x = x + 1 
      con.notify() 
    print x 
    con.release() 
class Consumer(threading.Thread): 
  def __init__(self,threadname): 
    threading.Thread.__init__(self,name = threadname) 
  def run(self): 
    global x  
    con.acquire() 
    if x == 0: 
      con.wait() 
      #pass 
    else: 
      for i in range(1000000): 
        x = x - 1 
      con.notify() 
    print x  
    con.release() 
con = threading.Condition() 
x = 0 
p = Producer('Producer') 
c = Consumer('Consumer') 
p.start() 
c.start() 
p.join() 
c.join() 
print x 
 
E:/study/python/workspace>xianchengtongbu2.py 
1000000 
0 
0 

线程间通信：

Event对象用于线程间的相互通信。他提供了设置信号、清除信宏、等待等用于实现线程间的通信。

1、设置信号。Event对象使用了set()方法后，isSet()方法返回真。
2、清除信号。使用Event对象的clear（）方法后，isSet（）方法返回为假。
3、等待。当Event对象的内部信号标志为假时，则wait()方法一直等到其为真时才返回。还可以向wait传递参数，设定最长的等待时间。

# -*- coding:utf-8 -*- 
import threading 
class mythread(threading.Thread): 
  def __init__(self,threadname): 
    threading.Thread.__init__(self,name = threadname) 
  def run(self): 
    global event 
    if event.isSet(): 
      event.clear() 
      event.wait()  #当event被标记时才返回 
      print self.getName() 
    else: 
      print self.getName() 
      event.set() 
event = threading.Event() 
event.set() 
t1 = [] 
for i in range(10): 
  t = mythread(str(i)) 
  t1.append(t) 
for i in t1: 
  i.start() 

如有疑问请留言或者到本站社区交流讨论，感谢 阅读，希望能帮助到大家，谢谢大家对本站的支持！

# Python  # 多线程  # 多线程的详解  # python 对类的成员函数开启线程的方法  # python并发编程之线程实例解析  # python回调函数中使用多线程的方法  # Python开启线程  # 在函数中开线程的实例  # 还可以  # 对其  # 全局变量  # 可选  # 时才  # 放在  # 如有  # 已被  # 设为  # 其他的  # 会在  # 希望能  # 将是  # 第二个  # 只有一个  # 可以实现  # 谢谢大家  # 则可  # 后才  # 方法来 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： 如何用5美元大硬盘VPS安全高效搭建个人网站？  php做exe能调用系统命令吗_执行cmd指令实现方式【详解】  Laravel如何使用Gate和Policy进行权限控制_Laravel权限判定与策略规则配置  Laravel如何处理JSON字段的查询和更新_Laravel JSON列操作与查询技巧  详解一款开源免费的.NET文档操作组件DocX（.NET组件介绍之一）  什么是javascript作用域_全局和局部作用域有什么区别？  怎么用AI帮你为初创公司进行市场定位分析？  Android使用GridView实现日历的简单功能  lovemo网页版地址 lovemo官网手机登录  Java解压缩zip - 解压缩多个文件或文件夹实例  Firefox Developer Edition开发者版本入口  Laravel如何实现文件上传和存储？（本地与S3配置）  Midjourney怎么调整光影效果_Midjourney光影调整方法【指南】  百度浏览器如何管理插件 百度浏览器插件管理方法  Laravel如何获取当前用户信息_Laravel Auth门面获取用户ID  Laravel API资源类怎么用_Laravel API Resource数据转换  用yum安装MySQLdb模块的步骤方法  如何在局域网内绑定自建网站域名？  Android Socket接口实现即时通讯实例代码  高性能网站服务器部署指南：稳定运行与安全配置优化方案  Claude怎样写结构化提示词_Claude结构化提示词写法【教程】  微博html5版本怎么弄发语音微博_语音录制入口及时长限制操作【教程】  Laravel如何实现登录错误次数限制_Laravel自带LoginThrottles限流配置【方法】  免费网站制作appp,免费制作app哪个平台好？  如何生成腾讯云建站专用兑换码？  Laravel如何处理表单验证？（Requests代码示例）  如何在 Python 中将列表项按字母顺序编号（a.、b.、c. …）  Swift中循环语句中的转移语句 break 和 continue  高防服务器租用首荐平台，企业级优惠套餐快速部署  使用C语言编写圣诞表白程序  JavaScript实现Fly Bird小游戏  Laravel如何使用集合（Collections）进行数据处理_Laravel Collection常用方法与技巧  怎么用AI帮你设计一套个性化的手机App图标？  如何用花生壳三步快速搭建专属网站？  无锡营销型网站制作公司,无锡网选车牌流程？  微信小程序 闭包写法详细介绍  Laravel如何实现全文搜索_Laravel Scout集成Algolia或Meilisearch教程  浅谈javascript alert和confirm的美化  如何用PHP工具快速搭建高效网站？  Laravel如何与Docker（Sail）协同开发？（环境搭建教程）  如何快速生成ASP一键建站模板并优化安全性？  Swift开发中switch语句值绑定模式  如何快速生成橙子建站落地页链接？  Laravel怎么定时执行任务_Laravel任务调度器Schedule配置与Cron设置【教程】  ChatGPT回答中断怎么办 引导AI继续输出完整内容的方法  如何快速查询域名建站关键信息？  如何在IIS中配置站点IP、端口及主机头？  简单实现Android文件上传  独立制作一个网站多少钱,建立网站需要花多少钱？  ,网页ppt怎么弄成自己的ppt？