简介
在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()

