登录 |  注册 |  繁體中文


Python线程

分类: python 颜色:橙色 默认  字号: 阅读(774) | 评论(0)

简介

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




姓 名: *
邮 箱:
内 容: *
验证码: 点击刷新 *   

回到顶部