python的多线程编程 --- thread模块

1、使用thread模块(不推荐)

常用函数:

‘start_new_thread(function,args,kwargs=None)’:创建一个新的线程,并运行’function(args)’

‘allocate_lock()’: 创建锁对象 Lock object

‘exit()’: 提示线程退出

Lock的函数:

‘acquire(wait=None)’: 获取lock对象或等待wait时间

‘locked()’ 获得lock返回true,否则返回false

‘release’ :释放lock

例子1:

import thread
from time import sleep,ctime
def loop0():
    print ‘start loop 0"
def main():
    thread.start_new_thread(loop0,())
    sleep(6)
if __name__==‘__main__‘:
    main()

注意:1、虽然loop0不接受参数,但’start_new_thread’中的空tuple不能够省略;

2、使用sleep,因为在主线程创建线程后,主线程会继续运行直到退出,同时杀死所有的子线程,而不做任何的检查,这也是不推荐使用thread模块的原因之一。

例子2:

import thread
from time import sleep,ctime
loops=[4,2]
def loop(nloop,nsec,lock):
    print ‘start loop‘,nloop,‘at:‘,ctime()
    lock.release()
def main():
    print ‘starting‘
    locks=[]
    nloops = range(len(loops))
    for i in nloops:
        lock=thread.allocate_lock()
        lock.acquire()
        locks.append(lock)
    for i in nloops:
        thread.start_new_thread(loop,(i,loops[i],locks[i])
    for i in nloops:
        while locks[i].locked(): pass
    print ‘all done‘
if __name__==‘__main__‘:
    main()

多个线程间可以通过共享lock,防止资源访问的冲突

时间: 2024-07-29 22:02:00

python的多线程编程 --- thread模块的相关文章

【python】多线程编程

使用多线程编程和一个共享的数据结构如queue,这种程序任务可以用多个功能单一的线程来组织: UserRequestThread:负责读取客户的输入,可能是一个I/O信道.程序可能创建多个线程,每个客户一个,请求会被放入队列中 RequestProcessor:一个负责从队列中获取并处理请求的线程,它为下面那种线程提供输出 ReplyThread:负责把给用户的输出取出来,如果是网络应用程序就把结果发送出去,否则就保存到本地文件系统或数据库中. 一个顺序执行单线程的例子: from time i

Python的多线程和多进程模块对比测试

本文主要对比测试Python的多线程和多进程模块在CPU类型和I/O的任务操作时的效率 一 测试CPU消耗类型任务 在一台多核CPU的服务器上执行多线程代码,理论上代码执行时会利用多余的CPU核心来提升性能.但是由于Python的GIL的存在,使用多线程来执行CPU繁重的任务,未必能得到性能提升.但是GIL又必不可少,因为在Python解释器中执行线程是不安全的,也就是说为了保证Python线程执行时的安全,Python提供了一个全局锁,同一时刻,只允许一个线程获得这个全解锁并执行. CPU消耗

python多线程编程----threading模块

1.threading 模块中的内容 - Thread: 一个可执行线程对象 - Lock: 原始的Lock对象 与thread模块中一样 - RLock: 允许单个线程多次请求的Lock - Condition: 线程等待直到条件满足 - Event : 事件发生时,唤醒所有等待进程 - Semaphore:信号量,标识有限资源的个数 - Timer: 定时启动线程 - Barrier: 等待指定的所有的进程都来到 2.daemon threads 守护进程 如果你的主线程准备退出,并且你并不

Python的多线程编程

提到多线程,很多人就会望而却步,本文将由浅入深地带你攻克python多线程编程,并防止你跳入深坑, 首先看一段简单的代码: 1 from time import ctime,sleep 2 def play_video(video): 3 for i in range(2): 4 print "i am playing video: %s at %s"%(video,ctime()) 5 sleep(4) 6 7 8 def play_music(music): 9 for i in

Python threading多线程编程示例

Python 的多线程有两种实现方法: 函数,线程类 1.函数 调用 thread 模块中的 start_new_thread() 函数来创建线程,以线程函数的形式告诉线程该做什么 # -*- coding: utf-8 -*- import thread def f(name): #定义线程函数 print "this is " + name if __name__ == '__main__': thread.start_new_thread(f, ("thread1&qu

Python之多线程:Threading模块

1.Threading模块提供的类 Thread,Lock,Rlock,Condition,Semaphore,Event,Timer,local 2.threading模块提供的常用的方法 (1)threading.currentThread(): 返回当前的线程变量. (2)threading.enumerate(): 返回一个包含正在运行的线程的list.正在运行指线程启动后.结束前,不包括启动前和终止后的线程. (3)threading.activeCount():返回正在运行的线程数量

41 Python - python并行编程 多线程之——thread模块(已经过时,开发不推荐)

多线程并非并发编程的唯一技术手段,但是用的比较多的还是多线程. 001 单线程例子 创建文件 002 多线程例子 缺点没有控制进程结束的机制 _thread已经不推荐使用了(所以前面有有个下划线),学习阶段用于实验 (1)新建文件 函数_thread(第一个参数,第二个参数) 第一个参数,只需要写函数名,不用加括号 第二个参数,需要是元组形式 但是结果不正确,因为主线程没有等待子线程,一运行就结束了 (2)改进主线程让其等待子线程结束再结束 改进main函数,让主线程等待一下6秒等待子线程结束

python多线程编程-queue模块和生产者-消费者问题

摘录python核心编程 本例中演示生产者-消费者模型:商品或服务的生产者生产商品,然后将其放到类似队列的数据结构中.生产商品中的时间是不确定的,同样消费者消费商品的时间也是不确定的. 使用queue模块(python2.x版本中,叫Queue)来提供线程间通信的机制,从而让线程之间可以分享数据.具体而言,就是创建一个队列,让生产者(线程)在其中放入新的商品,而消费者(线程)消费这些商品. 下表是queue模块的部分属性: 属性 描述 queue模块的类 Queue(maxsize=0) 创建一

Python3 多线程编程 threading模块

性能自动化测试除了用jmeter还可以用python threading模块做 一.threading模块定义 Python 2.4中包含的较新的线程模块为线程提供了更强大的高级支持. 线程模块公开线程模块的所有方法,并提供一些额外的方法 activecount()——返回活动的线程对象的数量. currentthread()——返回调用方线程控件中线程对象的数量. enumerate()——返回当前活动的所有线程对象的列表. 除了方法之外,线程模块还有实现线程的Thread类实现了hreadi