简介
在Python提供了多个模块支持多线程编程,包括thread,threading和Queue模块等,推荐使用threading
threading模块对象
对象 | 描述 |
---|---|
Thread | 表示一个执行线程的对象 |
Lock | 锁原语对象 |
RLock | 可重入锁对象,使单一线程可以(再次)获得已持有的锁(递归锁) |
Condition | 条件变量对象,使得一个线程等待另一个线程满足特定的“条件”,比如改变状态或某个数据值 |
Event | 条件变量的通用版本,任意数量的线程等待某个事件的发生,在该事件发生后所有线程将被激活 |
Semaphore | 为线程间共享的有限资源提供了一个“计数器”,如果没有可用资源时会被阻塞 |
BoundedSemaphore | 与 Semaphore 相似,不过它不允许超过初始值 |
Timer | 与 Thread 相似,不过它要在运行前等待一段时间 |
Barrier | 创建一个障碍,必须达到指定数量的线程才可以继续 |
Thread类属性和方法
Thread 对象数据属性
threading.Thread(group=None, target=None, name=None, args=(), kwargs={}, *, daemon=None)
Thread 对象数据属性 | 描述 |
---|---|
name | 线程名 |
ident | 线程的标识符 |
daemon | 布尔标志,表示这个线程是否是守护线程 |
Thread 对象方法
Thread 对象方法 | 描述 |
---|---|
__init__(group=None, tatget=None,args=(), kwargs ={}, verbose=None, daemon=None) | 实例化一个线程对象,需要有一个可调用的 target,以及其参数 args或 kwargs。还可以传递 name 或 group 参数,不过后者还未实现。此外 , verbose 标 志 也 是 可 接 受 的。 而 daemon 的 值 将 会 设定thread.daemon 属性/标志 |
start() | 开始执行该线程 |
run() | 定义线程功能的方法(通常在子类中被应用开发者重写) |
join (timeout=None) | 直至启动的线程终止之前一直挂起;除非给出了 timeout(秒),否则会一直阻塞 |
getName() | 返回线程名 |
setName (name) | 设定线程名 |
isAlivel /is_alive () | 布尔标志,表示这个线程是否还存活 |
isDaemon() | 如果是守护线程,则返回 True;否则,返回 False |
setDaemon(daemonic) | 把线程的守护标志设定为布尔值 daemonic(必须在线程 start()之前调用) |
示例1:创建Thread实例,传递函数
import threading import time def read(): for x in range(3): print(在%s,正在读书 % time.ctime()) time.sleep(1) def write(): for x in range(3): print(在%s,正在写字 % time.ctime()) time.sleep(1) def main(): read_threads = [] # 用来存放执行read函数线程的列表 write_threads = [] # 用来存放执行write函数线程的列表 for i in range(1,2): # 创建1个线程用于read(),并添加到read_threads列表 t = threading.Thread(target=read) # 执行的函数如果需要传递参数,threading.Thread(target=函数名,args=(参数,逗号隔开)) read_threads.append(t) for i in range(1,2): # 创建1个线程执行write(),并添加到write_threads列表 t = threading.Thread(target=write) # 执行的函数如果需要传递参数,threading.Thread(target=函数名,args=(参数,逗号隔开)) write_threads.append(t) for i in range(0,1): # 启动存放在read_threads和write_threads列表中的线程 read_threads[i].start() write_threads[i].start() if __name__ == __main__: main()